Hi Were you able to figure out this issue? Any clue ?
Regards Saravanan On Wednesday, August 9, 2017 at 11:51:19 PM UTC-5, Raghav wrote: > > 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 >
