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:47
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 <[EMAIL PROTECTED]>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 <[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
>>
>
>