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)
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
