Cygnus stellt keine Verbindung zum Kafka-Broker her

Question

Ich verwende den cygnus-kafka-Konnektor. wenn die Verbindung zwischen Cygnus und dem Tierpfleger verloren geht. Cygnus kann sich nicht wieder mit dem Tierpfleger verbinden, wenn die Verbindung wieder hergestellt ist. Ich muss es neu starten, damit es sich wieder mit dem Tierpfleger verbinden kann.

Irgendwelche Ideen, warum Cygnus nicht in der Lage ist, die Verbindung zum Kafka-Broker wiederherzustellen, wenn die Verbindung einmal verloren gegangen ist? Diese

die Fehler, die ich habe:

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 

Dank!

Answer 1

Das Problem ist die Verbindung von Cygnus zu Kafka ist permanent, wegen der Effizienz Probleme. Trotzdem fehlt im Code eine Überprüfung auf eine zurückgesetzte Verbindung durch Peer. Ich werde es so schnell wie möglich reparieren, bis es fertig ist für die nächste Version (1.7.0) bis Ende Januar (natürlich wird es bei master Branch einmal fester, viel früher verfügbar sein).