You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/11/24 06:48:28 UTC
[camel-kafka-connector] 09/17: Fixed CS
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-master-align-and-rebase
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit cfc6e178358f1917bbd44cd0ee69110f5fc23ae0
Author: Andrea Cosentino <an...@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;
}