This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push: new 6cb2a76 [camel-kafka] remove invalid property for SEND_BUFFER_CONFIG (#3304) 6cb2a76 is described below commit 6cb2a7617e5eab309057e584ec63f844610ed7c2 Author: Nastya Smirnova <zmin...@gmail.com> AuthorDate: Thu Oct 31 16:37:39 2019 +0200 [camel-kafka] remove invalid property for SEND_BUFFER_CONFIG (#3304) --- .../main/java/org/apache/camel/component/kafka/KafkaConfiguration.java | 1 - 1 file changed, 1 deletion(-) 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 02db043..c561de9 100644 --- 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 @@ -337,7 +337,6 @@ public class KafkaConfiguration implements Cloneable, HeaderFilterStrategyAware addPropertyIfNotNull(props, ProducerConfig.COMPRESSION_TYPE_CONFIG, getCompressionCodec()); addPropertyIfNotNull(props, ProducerConfig.RETRIES_CONFIG, getRetries()); addPropertyIfNotNull(props, ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, getInterceptorClasses()); - addPropertyIfNotNull(props, ProducerConfig.SEND_BUFFER_CONFIG, getRetries()); addPropertyIfNotNull(props, ProducerConfig.BATCH_SIZE_CONFIG, getProducerBatchSize()); addPropertyIfNotNull(props, ProducerConfig.CLIENT_ID_CONFIG, getClientId()); addPropertyIfNotNull(props, ProducerConfig.CONNECTIONS_MAX_IDLE_MS_CONFIG, getConnectionMaxIdleMs());