aul Mackles wrote:
>
>> Thanks. Thread dump from hung producer app here:
>>
>> https://gist.github.com/4082265
>>
>> In case anyone has any insights.
>>
>> On 11/15/12 5:30 PM, "Neha Narkhede" wrote:
>>
>> >Paul,
>> >
Thanks. Thread dump from hung producer app here:
>
> https://gist.github.com/4082265
>
> In case anyone has any insights.
>
> On 11/15/12 5:30 PM, "Neha Narkhede" wrote:
>
> >Paul,
> >
> >This behavior is unexpected and the code suggests QueueFullEx
Thanks. Thread dump from hung producer app here:
https://gist.github.com/4082265
In case anyone has any insights.
On 11/15/12 5:30 PM, "Neha Narkhede" wrote:
>Paul,
>
>This behavior is unexpected and the code suggests QueueFullException
>is thrown back to the caller.
Paul,
This behavior is unexpected and the code suggests QueueFullException
is thrown back to the caller. I would take a thread dump when the
producer is blocked to see what's causing the blocking behavior.
Thanks,
Neha
On Thu, Nov 15, 2012 at 12:53 PM, Paul Mackles wrote:
> I am tinker
I am tinkering with the java async producer from kafka 7.2 and I am trying to
write a client that will never block when sending messages to a kafka broker
(dropping them would be better than blocking). I can send messages at a rate
that is fast enough to trigger a QueueFullException but the
