Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Configuration ParameterExampleDescription
source.bootstrap.serverssource.broker1:9092,source.broker2:9092Mandatory. Comma separated list of boostrap servers for the source Kafka cluster
source.topic.whitelisttopic, topic-prefix*Java regular expression to match topics to mirror. For convenience, comma (',') is interpreted as the regex-choice symbol ('|').
source.auto.offset.resetlatestIf there is no stored offset for a partition, indicates where to start consuming from. Options are "earliest"or "latest". Default: earliest
source.group.idkafka-connectGroup ID used when writing offsets back to source cluster (for offset lag tracking)
destination.topics.prefixaggregate.Prefix to add to source topic names when determining the Kafka topic to publish data to

...