[ https://issues.apache.org/jira/browse/BEAM-7299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alexey Romanenko resolved BEAM-7299. ------------------------------------ Fix Version/s: Not applicable Resolution: Won't Fix I close this one since it was fixed in other Jira issue and no more feedback was provided. Please, reopen this if there is still a problem. > Upgrade kafka client for KafkaIO to support new compression zstd > ---------------------------------------------------------------- > > Key: BEAM-7299 > URL: https://issues.apache.org/jira/browse/BEAM-7299 > Project: Beam > Issue Type: Improvement > Components: io-java-kafka > Affects Versions: 2.12.0 > Reporter: Evgeny > Priority: Major > Fix For: Not applicable > > > Current io-java-kafka dependency contains kafka-clients 1.0.0 which does not > support new compression type of Kafka 2.1.1 "zstd". -- This message was sent by Atlassian Jira (v8.3.4#803005)