Details
-
Type: extRequest
-
Status: Closed
-
Priority: Major
-
Resolution: Done
-
Fix Version/s: 2021
-
Component/s: FIWARE-TECH-HELP
-
Labels:None
-
Sender Email:
-
HD-Chapter:Data
-
HD-Enabler:Cosmos
Description
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@eglobalmark.com <sabrine.fatnassi@eglobalmark.com>
Since January 1st, old domains won't be supported and messages sent to any domain different to @lists.fiware.org will be lost.
Please, send your messages using the new domain (Fiware-tech-help@lists.fiware.org) instead of the old one.
_______________________________________________
Fiware-tech-help mailing list
Fiware-tech-help@lists.fiware.org
https://lists.fiware.org/listinfo/fiware-tech-help
[Created via e-mail received from: "Sabrine Fatnassi (EGM)" <sabrine.fatnassi@eglobalmark.com>]
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/
Email : sabrine.fatnassi@eglobalmark.com <sabrine.fatnassi@eglobalmark.com>