You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Jon Yeargers <jo...@cedexis.com> on 2017/01/01 19:23:06 UTC

EOF exceptions - 0.10.2.0-SNAPSHOT

(Ive been testing against the latest from github as 0.10.1.1 is too buggy)

Seeing quite a few of these this morning:

2017-01-01 16:56:53,299 [StreamThread-1] DEBUG
o.a.kafka.common.network.Selector - Connection with /<ip address>
disconnected

java.io.EOFException: null

        at
org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83)

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

        at
org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:169)

        at
org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:150)

        at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:355)

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

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

        at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:235)

        at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:181)

        at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:309)

        at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:278)

        at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:261)

        at
org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1039)

        at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1004)

        at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:570)

        at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:359)

Re: EOF exceptions - 0.10.2.0-SNAPSHOT

Posted by Guozhang Wang <wa...@gmail.com>.

This is not an error message, and it is not specific to Streams. It simply
indicates that the server has (probably temporarily) dropped the connection
which may be due to a bunch of reasons: server node slow, network unstable,
etc, and that is why it is only logged as a debug entry. The consumer
client in this case will try auto-reconnect to the broker in the next
iteration.


Guozhang

On Sun, Jan 1, 2017 at 11:23 AM, Jon Yeargers <jo...@cedexis.com>
wrote:

> (Ive been testing against the latest from github as 0.10.1.1 is too buggy)
>
> Seeing quite a few of these this morning:
>
> 2017-01-01 16:56:53,299 [StreamThread-1] DEBUG
> o.a.kafka.common.network.Selector - Connection with /<ip address>
> disconnected
>
> java.io.EOFException: null
>
>         at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(
> NetworkReceive.java:83)
>
>         at
> org.apache.kafka.common.network.NetworkReceive.
> readFrom(NetworkReceive.java:71)
>
>         at
> org.apache.kafka.common.network.KafkaChannel.receive(
> KafkaChannel.java:169)
>
>         at
> org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:150)
>
>         at
> org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.
> java:355)
>
>         at org.apache.kafka.common.network.Selector.poll(
> Selector.java:303)
>
>         at
> org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:341)
>
>         at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(
> ConsumerNetworkClient.java:235)
>
>         at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(
> ConsumerNetworkClient.java:181)
>
>         at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator.
> joinGroupIfNeeded(AbstractCoordinator.java:309)
>
>         at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator.
> ensureActiveGroup(AbstractCoordinator.java:278)
>
>         at
> org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(
> ConsumerCoordinator.java:261)
>
>         at
> org.apache.kafka.clients.consumer.KafkaConsumer.
> pollOnce(KafkaConsumer.java:1039)
>
>         at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(
> KafkaConsumer.java:1004)
>
>         at
> org.apache.kafka.streams.processor.internals.StreamThread.runLoop(
> StreamThread.java:570)
>
>         at
> org.apache.kafka.streams.processor.internals.
> StreamThread.run(StreamThread.java:359)
>



-- 
-- Guozhang