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