________________________________
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
