DataDog/brod — Issue #7: Compression support
Author: ormsbee
Created: 2012-01-11 20:31:43+00:00
State: open

We don't support compressed messages yet, as per:

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

(I have a description of it https://cwiki.apache.org/confluence/display/KAFKA/Writing+a+Driver+for+Kafka as well, though I can't verify the accuracy of it yet.)

Implementing this will probably also mean shifting the parsing of messages to the MessageSet class, so that it can calculate the offsets properly.