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;
                 }

Reply via email to