当我试图阅读Kafka的作品时，我遇到了以下错误
java.lang.IllegalArgumentException: Unknown compression type id: 5
at org.apache.kafka.common.record.CompressionType.forId(CompressionType.java:46)
at org.apache.kafka.common.record.Record.compressionType(Record.java:260)
at org.apache.kafka.common.record.LogEntry.isCompressed(LogEntry.java:89)
at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:70)
at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:34)
at org.apache.kafka.common.utils.AbstractIterator.maybeComputeNext(AbstractIterator.java:79)
at org.apache.kafka.common.utils.AbstractIterator.hasNext(AbstractIterator.java:45)
at org.apache.kafka.clients.consumer.internals.Fetcher.parseCompletedFetch(Fetcher.java:772)
at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:473)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1038)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:995)
at org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread.run(KafkaConsumerThread.java:243)你知道这可能是什么或者我应该去哪里找吗？
2条答案
按热度按时间kzipqqlq1#
我也面临同样的问题，因为它的客户不兼容的版本和主题上创建的Kafka旧版本。
检查您的Kafka消费客户端版本和Kafka版本。
mec1mxoz2#
kafka支持这些压缩编解码器-none、gzip、snappy、lz4、zstd。压缩类型介于0-4之间（如下链接所述）
https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/record/compressiontype.java#l169
如果您使用的压缩编解码器不同于这些，则需要将其更改为kafka支持的压缩编解码器。