If you are using the console consumer from the 0.8/bin directory then it
should be automatically updated when you package the kafka jar. Is your
console consumer using a separate kafka jar that did not possibly get
updated when you did git pull?
Thanks,
Swapnil
On 2/28/13 12:04 AM, "ben fleis" w
Is it possible to upgrade one without upgrading the other? I did a git
pull, ./sbt update package. Then for kicks I did sbt clean package, just
to be sure.
ben
Did you upgrade your console consumer?
Thanks,
Jun
On Wed, Feb 27, 2013 at 3:40 AM, ben fleis wrote:
> Sorry, I should have clarified something -- using the normal
> ConsoleConsumer does *not* produce this error. So something in my
> formatter, or in the logic of a custom formatter must chang
Sorry, I should have clarified something -- using the normal
ConsoleConsumer does *not* produce this error. So something in my
formatter, or in the logic of a custom formatter must change?
ben
Hi Swapnil,
I have done exactly this (killed and wiped everything), and have found that
my custom formatter based ConsoleConsumer fails:
[2013-02-27 12:34:31,420] ERROR Error processing message, stopping
consumer: (kafka.consumer.ConsoleConsumer$)
java.lang.NumberFormatException: For input strin
