Message passing to kafka fails with zstd compression codec #5106
Closed
RamHaridas
started this conversation in
General
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
I am trying to send messages from fluentd to kafka using compression codec zstd
The above config works well for gzip, snappy and lz4 compressions. but it fails for zstd with below error 😟
Fluentd version: 1.16.9 (tried with 1.19.0 as well)
gem Rdkafka version: 0.12.1 (tried with 0.21.2 as well)
gem fluent-plugin-kafka: 0.19.3
I wanted to confirm that whether the rdkafka gem by default supports zstd compression or not ?
Beta Was this translation helpful? Give feedback.
All reactions