Apologies for not responding sooner. My mail client must have been
malfunctioning at the time as I never saw your responses until today.
As for the error, it looks like it's a bug on my part that just didn't click
until I read Jim's responses. I have a config file that I specify the options
I'll try that out. Thanks!
From: Jun Rao [jun...@gmail.com]
Sent: Monday, December 10, 2012 1:04 PM
To: users@kafka.apache.org
Subject: Re: Logging which broker a message was sent to
So, you are using Producer, not SyncProducer. Assuming that you are
Hi,
Thanks Neha.
We made protocol changes up until last Friday, so I would wait for
another few weeks before deploying 0.8 in production, if you'd like to
avoid incompatible releases. However, upgrading from 0.7.2 to 0.8 is
also backwards incompatible and will require careful deployment
You can take a look at one of the producer tests and attach
breakpoints in the code. Ensure you pick the Debug Test instead of Run
Test option.
Thanks,
Neha
On Mon, Dec 10, 2012 at 7:31 PM, S Ahmed sahmed1...@gmail.com wrote:
Hi,
So I followed the instructions from here:
Neha,
But what do I need to start before running the tests, I tried to run the
test testAsyncSendCanCorrectlyFailWithTimeout but I got this:
2012-12-11 00:01:08,974] WARN EndOfStreamException: Unable to read
additional data from client sessionid 0x13b8856456a0002, likely client has
closed socket
BTW, where exactly will the broker be writing these messages? Is it in a
/tmp folder?
On Tue, Dec 11, 2012 at 12:02 AM, S Ahmed sahmed1...@gmail.com wrote:
Neha,
But what do I need to start before running the tests, I tried to run the
test testAsyncSendCanCorrectlyFailWithTimeout but I got
