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;