Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - Change in Message Format?


Copy link to this message
-
Re: Change in Message Format?
Jeffrey Damick 2011-10-17, 13:39
I see that as well, but not when the message is sent from the python
producer, and not in the scala producer / consumer pair.  I'll take a deeper
look.
2011/10/17 09:37:40 checksum mismatch, expected: 5E181719 was: 005129F3
2011/10/17 09:37:41 Fatal Error:  Error Decoding Message
On Mon, Oct 17, 2011 at 1:13 AM, Aaron Raddon <[EMAIL PROTECTED]> wrote:

> Hello, I am running the intro quickstart examples, (compiled from src)
> and getting an error from the go client consumer example.   The
> http://incubator.apache.org/kafka/quickstart.html shows this:
>
> > bin/kafka-producer-shell.sh --server kafka://localhost:9092 --topic test
> > hello
> > sent: hello (14 bytes)
>
> however, when i run it i get this (1 longer byte)
>
> > bin/kafka-producer-shell.sh --server kafka://localhost:9092 --topic test
> > hello
> > sent: hello (15 bytes)
>
> When i consume from the clients/go/tools/consumer i get an error:
>
> checksum mismatch, expected
>
> I was wondering if the message format possibly changed or possibly config
> error.
>
> Thanks
>