我已经在两个不同的主机上安装了 confluent Kafka,并尝试让 confluent 复制器工作。我已经严格遵循本教程中提到的内容。
启动复制器时我没有看到任何错误,这是我看到的日志:
WorkerSourceTask{id=replicator-source-0} 提交偏移量 (org.apache.kafka.connect.runtime.WorkerSourceTask:397([2019-03-26 06:38:15,049] INFO WorkerSourceTask{id=replicator-source-0} 刷新 0 偏移提交的未完成消息 (org.apache.kafka.connect.runtime.WorkerSourceTask:414(
我尝试在两个 kafka 服务器主机上运行复制器;我希望复制器在目标服务器上复制数据
我犯的错误是我在connect-standalone.properties中有源kafka值。但它应该是目的地卡夫卡。