You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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.
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
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.
Beta Was this translation helpful? Give feedback.
All reactions