Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 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?
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
>>
>
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB