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 <jun...@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 <arad...@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 > > >
