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
Which implies that compression.type=zstd is configured on the topic (broker-side config), but the client is using a FetchRequest version that is too old (<10).
The problem lies in librdkafka, it only implements FetchRequest versions 1, 2, 4 and 11, and broker 2.2.1 supports up to version 10, so librdkafka selects version 4 which does not support ZStd.
We'll fix this for the upcoming v1.5.0 release (mid june).
As a workaround I think you can set the broker's topic configuration compression.type=producer.
The text was updated successfully, but these errors were encountered:
confluentinc/confluent-kafka-python#858
--
This is from the AK source:
Which implies that compression.type=zstd is configured on the topic (broker-side config), but the client is using a FetchRequest version that is too old (<10).
The problem lies in librdkafka, it only implements FetchRequest versions 1, 2, 4 and 11, and broker 2.2.1 supports up to version 10, so librdkafka selects version 4 which does not support ZStd.
We'll fix this for the upcoming v1.5.0 release (mid june).
As a workaround I think you can set the broker's topic configuration
compression.type=producer
.The text was updated successfully, but these errors were encountered: