kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jeffrey Damick <jeffreydam...@gmail.com>
Subject Re: Change in Message Format?
Date Mon, 17 Oct 2011 13:47:02 GMT
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 <jeffreydamick@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 <araddon@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
>>
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message