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 <[email protected]>
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());