Cygnus 不会重新连接到 kafka 代理

Question

我正在使用 cygnus-kafka 连接器。当 cygnus 和 zookeeper 之间的连接丢失时。连接恢复后，cygnus 无法重新连接到 zookeeper。我需要重新启动它，以便它能够重新连接到动物园管理员。

如果连接丢失一次，为什么 cygnus 无法重新连接到 kafka 代理有什么想法吗？

这是我得到的错误：

time=2016-11-30T11:29:26.254Z | lvl=WARN | corr=2a924ba4-b6f0-11e6-8836-fa163e68f7a2 | trans=ce766745-ae85-415a-a6f3-0bed9f121e79 | srv=service| subsrv=/servicepath | function=run | comp=cygnusagent | msg=org.apache.zookeeper.ClientCnxn$SendThread[1185] : Session 0x0 for server kafkaServerIp/kafkaServerIp:2181, unexpected error, closing socket connection and attempting reconnect
java.io.IOException: Connection reset by peer
        at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
        at sun.nio.ch.IOUtil.read(IOUtil.java:192)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
        at org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:856)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1154)
time=2016-11-30T11:29:28.211Z | lvl=WARN | corr=2a924ba4-b6f0-11e6-8836-fa163e68f7a2 | trans=ce766745-ae85-415a-a6f3-0bed9f121e79 | srv=service| subsrv=/servicepath | function=processNewBatches | comp=cygnusagent | msg=com.telefonica.iot.cygnus.sinks.NGSISink[439] : Unable to connect to zookeeper server within timeout: 10000

谢谢！

Answer 1

问题是由于效率问题，从 Cygnus 到 Kafka 的连接是永久的。然而，代码中缺少对由对等方重置的连接的检查。我会尽快修复它，以便在 1 月底之前为下一个版本发布 (1.7.0) 做好准备（当然，修复后它将在 master 分支可用，更快）。

Cygnus 不会重新连接到 kafka 代理

Cygnus does not reconnect to kafka broker

fiware-cygnus