[Fiware-tech-help] Cygnus-Kafka sink

[Sabrine Fatnassi (EGM)]

Hello,

 

I am trying to connect Cygnus to Kafka

I am connected to the zookeeper but no values have been persisted in Kafka and I got this exception:

 

time=2016-02-24T11:48:24.197UTC | lvl=WARN | trans= | srv= | subsrv= | function=poll | comp=Cygnus | msg=org.apache.kafka.common.network.Selector[276] : Error in I/O with host myKafkaHostName/ myKafkaHostIP

java.io.EOFException

        at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:62)

        at org.apache.kafka.common.network.Selector.poll(Selector.java:248)

        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)

        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)

        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)

        at java.lang.Thread.run(Thread.java:745)

 

Any idea what is the cause?

 

 

Thanks & Best regards,

Sabrine FATNASSI

Test and Validation Engineer

 

Easy Global Market : http://www.eglobalmark.com/ <http://www.eglobalmark.com/> 

Email : sabrine.fatnassi at eglobalmark.com <mailto:sabrine.fatnassi at eglobalmark.com> 

 

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.fiware.org/private/fiware-tech-help/attachments/20160224/6b080c07/attachment.html>