This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 3b2c30623ca9aa734dba1d512e93fb35c6d68cf6 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Thu Nov 19 18:38:35 2020 +0100 Fixed CS --- .../org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java index 8f95655..c926bbc 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java @@ -203,8 +203,8 @@ public class CamelKafkaConnectMain extends SimpleMain { idempotentRepo = MemoryIdempotentRepository.memoryIdempotentRepository(memoryDimension); break; case "kafka": - idempotentRepo = new KafkaIdempotentRepository(idempotentRepositoryTopicName, idempotentRepositoryKafkaServers); - break; + idempotentRepo = new KafkaIdempotentRepository(idempotentRepositoryTopicName, idempotentRepositoryKafkaServers); + break; default: break; }