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