This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-3.x in repository https://gitbox.apache.org/repos/asf/camel.git
commit d44c275f0fd7ac78189bd53176c3aeb53a264c23 Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Apr 5 11:08:07 2023 +0200 CAMEL-19180 - Kafka Idempotent Repository does not give the user control over a randomized group id if the kafka broker requires the id to be in a specified form Signed-off-by: Andrea Cosentino <[email protected]> --- .../processor/idempotent/kafka/KafkaIdempotentRepository.java | 3 ++- .../kafka/integration/KafkaConsumerIdempotentGroupIdIT.java | 7 ++++--- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java b/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java index 89debcfaeb9..07005a529a2 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java @@ -143,7 +143,8 @@ public class KafkaIdempotentRepository extends ServiceSupport implements Idempot this.pollDurationMs = pollDurationMs; } - public KafkaIdempotentRepository(String topic, String bootstrapServers, int maxCacheSize, int pollDurationMs, String groupId) { + public KafkaIdempotentRepository(String topic, String bootstrapServers, int maxCacheSize, int pollDurationMs, + String groupId) { this.topic = topic; this.bootstrapServers = bootstrapServers; this.maxCacheSize = maxCacheSize; diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentGroupIdIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentGroupIdIT.java index 09937f7542b..7d3f7f16a8d 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentGroupIdIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentGroupIdIT.java @@ -16,6 +16,8 @@ */ package org.apache.camel.component.kafka.integration; +import java.util.Arrays; + import org.apache.camel.BindToRegistry; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kafka.integration.common.KafkaTestUtil; @@ -27,8 +29,6 @@ import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.condition.DisabledIfSystemProperty; -import java.util.Arrays; - import static org.apache.camel.component.kafka.serde.KafkaSerdeHelper.numericHeader; @DisabledIfSystemProperty(named = "enable.kafka.consumer.idempotency.tests", matches = "false") @@ -39,7 +39,8 @@ public class KafkaConsumerIdempotentGroupIdIT extends KafkaConsumerIdempotentTes private int size = 200; @BindToRegistry("kafkaIdempotentRepository") - private KafkaIdempotentRepository testIdempotent = new KafkaIdempotentRepository("TEST_IDEMPOTENT", getBootstrapServers(), "test_1"); + private KafkaIdempotentRepository testIdempotent + = new KafkaIdempotentRepository("TEST_IDEMPOTENT", getBootstrapServers(), "test_1"); @BeforeEach public void before() {
