Description
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.
thanks