Must be the compression byte ( https://cwiki.apache.org/confluence/display/KAFKA/Compression), i'll add that support to the go client.
On Mon, Oct 17, 2011 at 9:39 AM, Jeffrey Damick <jeffreydam...@gmail.com>wrote: > 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 <arad...@gmail.com> 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 >> > >
