zookeeper日志中的couch base-Kafka-连接器错误

Question

我对Couchbase和Kafka很陌生。每当我在Couchbase桶中插入html" target="_blank">消息时，说“xyz”，连接器就会将其拾取并放入同名的kafka主题中，即“xyz“。到现在为止，一直都还不错。但在这里，我有一个kafka消费者正在运行，它阅读这个主题，并将其放入另一个主题中，比如“abc_123”，但这从未发生过。主要是我在动物园管理员（我作为kafka的一部分运行）中看到了这个错误，并想知道，这是不是我可以忽略的事情。

〔2017-07-13 23:39:10830〕信息处理sessionid时获得用户级KeeperException：0x15d3d09116b000d类型：create cxid:0x47b zxid:0x551 txntype:-1 reqpath:n/a错误路径：/couchbase-kafka-connector2/default/913错误：KeeperErrorCode=NodeExists for/couchbae-kafka-connector 2/default/913（org.apache.zookeeper.server.PrepRequestProcessor）

到目前为止，谷歌搜索还没有关于上述特定错误的答案，我很想知道为什么我总是在将消息放入沙发桶“xyz”时收到此错误。

顺便说一句，清理水桶，重新安装动物园管理员，Kafka，沙发基地都尝试过，但没有结果。我的 kafka 消费者代码非常标准，如果有帮助，我可以提供，但我对 zookeeper 控制台中看到的错误感到好奇。

Answer 1

如果您刚开始使用Kafka的Couchbase连接器，我建议您看看新的连接器：https://github.com/couchbase/kafka-connect-couchbase/，它不直接依赖于Zookeeper，更容易设置，更可靠。