Have you followed the wire protocol documented here - https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol
On Thu, Mar 27, 2014 at 3:22 AM, 小宇 <mocking...@gmail.com> wrote: > Hi, all > I'm working on snappy compression in our Node.js client ( > https://github.com/SOHU-Co/kafka-node),but I found the offset of message > always 0 after snappy compression, for example: <Buffer 00 00 00 00 00 00 > 00 00 00 00 00 19 3e 69 5f c8 00 00 00 00 00 00 00 00 00 0b 7b 22 6f 6e 65 > 22 3a 22 31 22 7d>, I try to test it in kafka-cosole-producer.sh, but it > seems not support snappy. So I can't figure out what's wrong with my > client. Did anyone encounter the same problem? > Thanks. >
