Hello,

  I am experimenting with Kafka. Let me explain in brief what I am trying
to do. I am listening messages from a very high-speed velocity bus,
processing them and pushing to a Kafka cluster. The Kafka cluster has 5
broker nodes (and a second setup has 10 broker nodes). I am facing an
always reproducible issue on both the setups that after throwing 66K
messages to any of the above configurations, I am getting a
FailedToSendMessage exception at the Kafka producers that are pushing the
processed messages to the Kafka cluster. I am unable to figure out like
what is the issue. One more info., if I batch 1000 messages in a single
push, then also the issue occurs after 66K throws. Thus, size of the push
is not playing a role here but the no. of pushes.

One more thing, when I set producer.type="async", the producers throw OOME
as soon as I run them.

Kindly let me know if you have faced similar issues or some point that I
may be missing.

I am unable to access http://chat.freenode.net/ as mentioned in Kafka
documentation.

-- 
Thanks & Regards,
Saurabh Verma,
India

Reply via email to