Thank you Raghav. Was it like you upgraded Kafka Broker or Clients or both.

Regards
Saravanan

On Wednesday, August 30, 2017 at 6:31:34 PM UTC-5, Raghav wrote:
>
> I was never able to debug this exception. I, unfortunately, moved to 
> Apache Kafka 10.2.1 from Confluent 3.2.1 and this issue went away.
>
> On Wed, Aug 30, 2017 at 11:46 AM, Saravanan Tirugnanum <vtsa...@gmail.com 
> <javascript:>> wrote:
>
>> 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
>>>
>> -- 
>> You received this message because you are subscribed to the Google Groups 
>> "Confluent Platform" group.
>> To unsubscribe from this group and stop receiving emails from it, send an 
>> email to confluent-platform+unsubscr...@googlegroups.com <javascript:>.
>> To post to this group, send email to confluent...@googlegroups.com 
>> <javascript:>.
>> To view this discussion on the web visit 
>> https://groups.google.com/d/msgid/confluent-platform/0d1e67c3-7b5e-4b96-bc2d-bd9ba79d5dc7%40googlegroups.com
>>  
>> <https://groups.google.com/d/msgid/confluent-platform/0d1e67c3-7b5e-4b96-bc2d-bd9ba79d5dc7%40googlegroups.com?utm_medium=email&utm_source=footer>
>> .
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
>
> -- 
> Raghav
>

Reply via email to