kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jay Kreps <jay.kr...@gmail.com>
Subject Re: Change in Message Format?
Date Mon, 17 Oct 2011 21:16:09 GMT
Do we have a list of which clients support the new format? I think the
backwards compatibility story is not that great, actually, because even
though the server supports both versions, mixing versions of clients will
cause problems.

-Jay

On Mon, Oct 17, 2011 at 7:29 AM, Jun Rao <junrao@gmail.com> wrote:

> 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