lz4 CompressionCodec example and RackAffinityGroupBalancer

[sandeepkhanzode]

Hello,
I am trying to use the segmentio Kafka library with Go and MSK.

Two questions:
(a) Is the lz4 compressioncodec working and tested? Maybe we are using it wrong, but there is no difference in the before and after sizes in the topic on the broker storages. Can someone please help with a simple working example for this? I checked the test Go file for that in the sources and that shows the usage, however, that didn't seem to work for my test but I could be missing some setting.

(b) https://segment.com/blog/kafka-optimization/ ... this is what we are trying to achieve, but do we have any examples that show the use of RackAffinityGroupBalancer and topicctl to effect this? Any start on the scripts would be very helpful.

Thanks.