You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/12/25 15:57:07 UTC

[camel] branch main updated: docs: camel-kafka - Enumerate all options for compressionCodec (#8948)

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

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 1cbf2b6f457 docs: camel-kafka - Enumerate all options for compressionCodec (#8948)
1cbf2b6f457 is described below

commit 1cbf2b6f457c74842e7ff843cc3908e1fc969caf
Author: Kengo Seki <se...@apache.org>
AuthorDate: Mon Dec 26 00:56:56 2022 +0900

    docs: camel-kafka - Enumerate all options for compressionCodec (#8948)
    
    Kafka supports zstd compression and Camel can leverage it without any
    code modification. But that option is not mentioned in the component
    document, so let's cover it.
---
 .../java/org/apache/camel/component/kafka/KafkaConfiguration.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
index ba2a1feea77..e62bf74497f 100755
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
@@ -179,7 +179,7 @@ public class KafkaConfiguration implements Cloneable, HeaderFilterStrategyAware
     @UriParam(label = "producer", defaultValue = "33554432")
     private Integer bufferMemorySize = 33554432;
     // compression.type
-    @UriParam(label = "producer", defaultValue = "none", enums = "none,gzip,snappy,lz4")
+    @UriParam(label = "producer", defaultValue = "none", enums = "none,gzip,snappy,lz4,zstd")
     private String compressionCodec = "none";
     // retries
     @UriParam(label = "producer", defaultValue = "0")
@@ -871,7 +871,7 @@ public class KafkaConfiguration implements Cloneable, HeaderFilterStrategyAware
 
     /**
      * This parameter allows you to specify the compression codec for all data generated by this producer. Valid values
-     * are "none", "gzip" and "snappy".
+     * are "none", "gzip", "snappy", "lz4" and "zstd".
      */
     public void setCompressionCodec(String compressionCodec) {
         this.compressionCodec = compressionCodec;