Kafka Fehler im I/O java.io.EOFException: null
Ich bin mit Kafka 0.8.2.0 (Scala 2.10). In meinen Logfiles sehe ich die folgende Meldung zeitweise. Dies scheint ein Problem, aber ich bin sowohl in meinem localhost.
Ist das eine Harmlose Fehlermeldung oder sollte ich etwas tun, um es zu vermeiden?
2015-10-30 14:12:38.015 WARN 4251 --- [ad | producer-1] [ ] o.apache.kafka.common.network.Selector : Error in I/O with localhost/127.0.0.1
java.io.EOFException: null
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)
Du musst angemeldet sein, um einen Kommentar abzugeben.
Dies ist ein wenig später zur party, aber kann jemand helfen - es hätte mir geholfen.
Was Sie sehen, geschieht, weil die Kafka-broker ist passiv schließen der Verbindung nach einer bestimmten Zeit der Untätigkeit ist überschritten. Es ist definiert durch das broker-Eigenschaft: verbindungen.max.im Leerlauf ist.ms - die Standardeinstellung ist 10 Minuten.
Offenbar die kafka-client in 0.8.x nicht die Ehre, die Einstellung und die Blätter idle-verbindungen offen. Sehen Sie die Warnung in deinen logs, aber es sollte keine schlechte Wirkung auf Ihre Bewerbung.
Mehr details hier: https://issues.apache.org/jira/browse/KAFKA-3205
Den broker-config ist hier dokumentiert: https://kafka.apache.org/090/documentation/#configuration
In dieser Tabelle finden Sie:
Hoffe, das hilft.
Scheint es, wie Ihre Produzenten nicht herstellen können-kafka-broker. Ich schlage vor, Sie versuchen, das senden Sie einige Nachrichten mit kafka-Konsole Hersteller um festzustellen, ob Ihr system ordnungsgemäß konfiguriert ist.