You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "lifa (Jira)" <ji...@apache.org> on 2022/07/11 14:21:00 UTC

[jira] [Created] (KAFKA-14065) kafka-clients version 2.3.0 can not process lz4 compression type

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)