对比下config/connect-distributed.properties和config/connect-standalone.properties

cat config/connect-distributed.properties  |grep -v "^#" |grep -v "^$" && \
echo "#############################" && \
cat config/connect-standalone.properties  |grep -v "^#" |grep -v "^$"

bootstrap.servers=localhost:9092
group.id=connect-cluster
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=true
value.converter.schemas.enable=true
offset.storage.topic=connect-offsets
offset.storage.replication.factor=1
config.storage.topic=connect-configs
config.storage.replication.factor=1
status.storage.topic=connect-status
status.storage.replication.factor=1
offset.flush.interval.ms=10000
#############################
bootstrap.servers=localhost:9092
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=true
value.converter.schemas.enable=true
offset.storage.file.filename=/tmp/connect.offsets
offset.flush.interval.ms=10000

ref

使用 Kafka Connect 将数据从 Apache Kafka 引入 Azure Cosmos DB for Apache Cassandra

• 标签 kafka