lifa created KAFKA-14065:
----------------------------
Summary: kafka-clients version 2.3.0 can not process lz4
compression type
Key: KAFKA-14065
URL: https://issues.apache.org/jira/browse/KAFKA-14065
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 2.3.0
Reporter: lifa
kafka-clients version 2.3.0 can not process message with lz4 compression type
set message compression type :lz4
exception :
org.apache.kafka.common.KafkaException: Received exception when fetching the
next record from xxx-2-0. If needed, please seek past the record to continue
consumption.
Caused by: org.apache.kafka.common.KafkaException: java.io.IOException: Stream
frame descriptor corrupted
Caused by: java.io.IOException: Stream frame descriptor corrupted
at
org.apache.kafka.common.record.KafkaLZ4BlockInputStream.readHeader(KafkaLZ4BlockInputStream.java:132)
at
org.apache.kafka.common.record.KafkaLZ4BlockInputStream.<init>(KafkaLZ4BlockInputStream.java:78)
at
org.apache.kafka.common.record.CompressionType$4.wrapForInput(CompressionType.java:110)
... 34 more
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
