Hey Martin I am using default setting for queue.enqueue.timeout.ms. since I have not set it my Java client. Network doesn't seem to time out either.
Could I be missing something else ? On Sat, Aug 12, 2017 at 5:18 AM, Martin Gainty <mgai...@hotmail.com> wrote: > > > ________________________________ > From: Raghav <raghavas...@gmail.com> > Sent: Thursday, August 10, 2017 12:51 AM > To: Users; confluent-platf...@googlegroups.com > Subject: How to debug - NETWORK_EXCEPTION > > Hi > > I am sending very small 32 byte message to Kafka broker in a tight loop > with 250ms sleep. I have one broker, 1 partition, and replication factor = > 1. > > After about 4200 messages, I get *following *error pasted below. > > How can I debug this error ? Can you please throw some ideas for me to > debug ? Stuck on this for a while now. Need help here. > > 17/08/10 04:46:58 WARN internals.Sender:307 Got error produce response with > correlation id 4205 on topic-partition topic04-0, retrying (2 attempts > left). Error: NETWORK_EXCEPTI > ON > 17/08/10 04:47:29 WARN internals.Sender:307 Got error produce response with > correlation id 4207 on topic-partition topic04-0, retrying (1 attempts > left). Error: NETWORK_EXCEPT$ON > 17/08/10 04:47:59 WARN internals.Sender:307 Got error produce response with > correlation id 4209 on topic-partition topic04-0, retrying (0 attempts > left). Error: NETWORK_EXCEPT$ON > java.util.concurrent.ExecutionException: > org.apache.kafka.common.errors.NetworkException: The server disconnected > before a response was received. > at > org.apache.kafka.clients.producer.internals.FutureRecordMetadata. > valueOrError(FutureRecordMetadata.java:65) > MG>i would check one of 2 possibilities : > MG>A)your network is timing out > MG>B)your message is queue is full > MG>i would check timeout first so > MG>in producer.properties check queue.enqueue.timeout.ms= > MG>https://kafka.apache.org/08/documentation.html > Apache Kafka<https://kafka.apache.org/08/documentation.html> > kafka.apache.org > Each partition is an ordered, immutable sequence of messages that is > continually appended to—a commit log. The messages in the partitions are > each assigned a ... > > MG>if you have zookeeper enabled check zookeeper.connection.timeout.ms in > both server.properties and consumer.properties > > MG>check consumer.timeout.ms in consumer.properties > > at > org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get( > FutureRecordMetadata.java:52) > at > org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get( > FutureRecordMetadata.java:25) > > -- > Raghav > -- Raghav
