As related to
KAFKA-79, the go consumer and producer needs to support the compression attribute per https://cwiki.apache.org/confluence/display/KAFKA/Compression.
Can someone assign this to me, i'll add support and create a patch.
|Status||Open [ 1 ]||Patch Available [ 10002 ]|
|Status||Patch Available [ 10002 ]||Open [ 1 ]|
[ i was referring to the 'message set' wire format:
* 4 byte size containing an integer N
* N message bytes as described in the message class
my 2 cents - It seems convoluted to store uncompressed messages inside compressed messages.. ]
Neha Narkhede made changes -
|Status||Open [ 1 ]||Resolved [ 5 ]|
|Resolution||Fixed [ 1 ]|