This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new e0a10a44538 [fix][io] Restore lz4 compression with Kafka IO connector 
after #25198 exclusion
e0a10a44538 is described below

commit e0a10a44538371d99dffd6a11826e52cee77bdd1
Author: Lari Hotari <[email protected]>
AuthorDate: Tue Apr 21 19:25:59 2026 +0300

    [fix][io] Restore lz4 compression with Kafka IO connector after #25198 
exclusion
    
    - lz4 compression with Kafka would break without this change
    
    (cherry picked from commit 49c0894d119c23862e5ac3cfacaf820489543a13)
---
 pulsar-io/kafka/pom.xml | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/pulsar-io/kafka/pom.xml b/pulsar-io/kafka/pom.xml
index 3dca9a52ada..354e8553024 100644
--- a/pulsar-io/kafka/pom.xml
+++ b/pulsar-io/kafka/pom.xml
@@ -92,6 +92,11 @@
       </exclusions>
     </dependency>
 
+    <dependency>
+      <groupId>at.yawk.lz4</groupId>
+      <artifactId>lz4-java</artifactId>
+    </dependency>
+
     <dependency>
       <groupId>io.confluent</groupId>
       <artifactId>kafka-schema-registry-client</artifactId>

Reply via email to