THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Configuration Parameter | Example | Description | ||
|---|---|---|---|---|
| source.bootstrap.servers | source.broker1:9092,source.broker2:9092 | Mandatory. Comma separated list of boostrap servers for the source Kafka cluster | ||
| source.auto.offset.reset | latest | If there is no stored offset for a partition, indicates where to start consuming from. Options are "earliest"or "latest". Default: earliest | ||
| source.topics | an.interesting.topic,all.of.these.* | topic.whitelist | topic, topic-prefix* | Java regular expression Comma separated list of topics, or java regular expressions to match topics to mirror. For convenience, comma (',') is interpreted as the regex-choice symbol ('|'). |
| destination.topics.prefix | aggregate. | Prefix to add to source topic names when determining the Kafka topic to publish data to | ||
...
For cases where the configuration for the KafkaConsumer and AdminClient diverges, you can use the more explicit "source.consumer." and "source.admin." configuration parameters to fine tune the settings used for each. This is especially useful in cases where you may need to pass authentication parameters to these clients.
Compatibility, Deprecation, and Migration Plan
...