我对couchbase和kafka还不熟悉。每当我在couchbase bucket中插入消息并说“xyz”时,connector就会把它拾起并放入Kafka的同名主题中,即“xyz”。到现在为止,一直都还不错。但这里我有一个Kafka消费者运行,阅读这个主题,并把另一个主题,说“\ U 123”,但从来没有发生过。主要是我在zookeeper(我作为Kafka的一部分运行)中看到了这个错误,我想知道,这是不是我可以忽略的东西。
[2017-07-13 23:39:10830]信息处理时获得用户级别keeperexceptionsessionid:0x15d3d09116b000d type:创建cxid:0x47b zxid:0x551txntype:-1 reqpath:n/a错误路径:/couchbase-kafka-connector2/default/913error:keepererrorcode = /couchbase-kafka-connector2/default/913的nodeexists(org.apache.zookeeper.server.prerequestprocessor)
谷歌搜索到目前为止还没有对上述具体错误的答案,我很想知道为什么我总是得到这个错误,只要把消息放进couchbase桶“xyz”。
顺便说一句,清理水桶,重新安装zookeeper,Kafka,沙发床都是没有结果的尝试。我的Kafka消费代码是相当标准的,我可以提供,如果这有帮助,但我好奇的错误,在zookeeper控制台看到。
1条答案
按热度按时间ibrsph3r1#
如果您刚开始使用Kafka的couchbase连接器,我建议您看看新的连接器:https://github.com/couchbase/kafka-connect-couchbase/它不直接依赖于zookeeper,设置简单,可靠性高。