kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <jun...@gmail.com>
Subject Re: Change in Message Format?
Date Mon, 17 Oct 2011 14:29:57 GMT
Aaron,

In order to support compression, we have to change the message header
slightly. Please take a look at the new header format.

https://cwiki.apache.org/confluence/display/KAFKA/Compression

Thanks,

Jun

On Sun, Oct 16, 2011 at 10:13 PM, 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