Cygnus не подключается к брокеру kafka

Я использую коннектор cygnus-kafka. когда теряется связь между лебедем и смотрителем зоопарка. cygnus не может снова подключиться к zookeeper, когда соединение восстановлено. Мне нужно перезапустить его, чтобы он смог снова подключиться к 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

Спасибо!


fiware-cygnus
person sabrina2020    schedule 30.11.2016    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Проблема в том, что соединение Cygnus с Kafka является постоянным из-за проблем с эффективностью. Тем не менее в коде отсутствует проверка сброса соединения по пиру. Я исправлю его как можно скорее, чтобы он был готов к выпуску следующей версии (1.7.0) к концу января (конечно, он будет доступен в ветке master после исправления, гораздо раньше).

person frb    schedule 20.12.2016
comment
Связанная проблема в Github: github.com/telefonicaid/fiware-cygnus/issues/1346 - person frb; 20.12.2016