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 >
