Iam新增Couchbase和Kafka。每當我向Couchbase桶中插入消息時,都會說「xyz」,連接器將它拾取並放入同名的kafka主題中,即「xyz」。到現在爲止還挺好。但在這裏,我有一個卡夫卡消費者正在閱讀這個話題,並將其放入另一個話題中說「abc_123」,但從未發生過。主要是iam在zookeeper(這是iaf作爲kafka的一部分運行)中看到這個錯誤,並想知道,如果這是我可以忽略或不能。動物園管理員日誌中的Couchbase-Kafka-連接器錯誤
[2017-07-13 23:39:10,830] INFO Got user-level KeeperException when processing sessionid:0x15d3d09116b000d type:create cxid:0x47b zxid:0x551 txntype:-1 reqpath:n/a Error Path:/couchbase-kafka-connector2/default/913 Error:KeeperErrorCode = NodeExists for /couchbase-kafka-connector2/default/913 (org.apache.zookeeper.server.PrepRequestProcessor)
谷歌搜索對上述特定錯誤和IAM好奇沒有答案,直到現在才知道爲什麼我總是一消息放入couchbase鬥「XYZ」得到這個錯誤。
順便說一句,清理桶,重新安裝zookeeper,kafka,couchbase都嘗試沒有結果。我的卡夫卡消費者代碼是非常標準的,我可以提供如果有幫助,但我好奇在zookeeper控制檯中看到的錯誤。