我在两个不同的主机上安装了confluent kafka,并尝试使confluent replicator正常工作。我严格遵循了本教程中提到的内容。
我在启动复制程序时没有看到任何错误,下面是我看到的日志:
workersourcetask{id=replicator-source-0}提交偏移量(org.apache.kafka.connect.runtime.workersourcetask:397)[2019-03-26 06:38:15049]info workersourcetask{id=replicator-source-0}刷新0个未完成的消息以进行偏移提交(org.apache.kafka.connect.runtime.workers)ourcetask:414)
我试着在两台kafka服务器主机上运行replicator;我希望复制器在目标服务器上复制数据
1条答案
按热度按时间siv3szwd1#
我犯的错误是在connect-standalone.properties中有源kafka值。但它应该是Kafka的目的地。