This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9c40842514d9eeaf9262970a397334adbc2cf1f7
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Wed Aug 3 17:06:20 2022 +0200
(chores) camel-kafka: avoid reusing the group ID
This can cause problems in slow systems as the test Kafka is configured to
a single partition
---
.../component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java | 2 +-
.../component/kafka/integration/KafkaConsumerBadPortHealthCheckIT.java | 2 +-
.../integration/KafkaConsumerBadPortSupervisingHealthCheckIT.java | 2 +-
.../apache/camel/component/kafka/integration/KafkaConsumerFullIT.java | 2 +-
.../camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java | 2 +-
.../camel/component/kafka/integration/KafkaConsumerIdempotentIT.java | 2 +-
.../integration/KafkaConsumerIdempotentWithCustomSerializerIT.java | 2 +-
.../kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java | 2 +-
.../component/kafka/integration/KafkaConsumerTopicIsPatternIT.java | 3 ++-
.../kafka/integration/KafkaConsumerUnresolvableHealthCheckIT.java | 2 +-
.../component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java | 2 +-
.../component/kafka/integration/commit/KafkaConsumerNoopCommitIT.java | 2 +-
.../component/kafka/integration/commit/KafkaConsumerSyncCommitIT.java | 2 +-
.../kafka/integration/pause/KafkaPausableConsumerCircuitBreakerIT.java | 2 +-
.../component/kafka/integration/pause/KafkaPausableConsumerIT.java | 2 +-
15 files changed, 16 insertions(+), 15 deletions(-)
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
index bfda5a5a5e8..7167273ad66 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
@@ -55,7 +55,7 @@ public class KafkaConsumerAsyncManualCommitIT extends
BaseEmbeddedKafkaTestSuppo
private static final Logger LOG =
LoggerFactory.getLogger(KafkaConsumerAsyncManualCommitIT.class);
@EndpointInject("kafka:" + TOPIC
- +
"?groupId=group1&sessionTimeoutMs=30000&autoCommitEnable=false"
+ +
"?groupId=KafkaConsumerAsyncManualCommitIT&sessionTimeoutMs=30000&autoCommitEnable=false"
+
"&allowManualCommit=true&autoOffsetReset=earliest&kafkaManualCommitFactory=#testFactory")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortHealthCheckIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortHealthCheckIT.java
index 0ca75d0b2b4..ccd43c965a4 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortHealthCheckIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortHealthCheckIT.java
@@ -70,7 +70,7 @@ public class KafkaConsumerBadPortHealthCheckIT extends
CamelTestSupport {
private MyKafkaHeaderDeserializer deserializer = new
MyKafkaHeaderDeserializer();
@EndpointInject("kafka:" + TOPIC
- +
"?groupId=group1&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&"
+ +
"?groupId=KafkaConsumerBadPortHealthCheckIT&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&"
+
"valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&autoCommitIntervalMs=1000&sessionTimeoutMs=30000&autoCommitEnable=true&interceptorClasses=org.apache.camel.component.kafka.MockConsumerInterceptor")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortSupervisingHealthCheckIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortSupervisingHealthCheckIT.java
index 31727cae3fd..e1754999802 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortSupervisingHealthCheckIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortSupervisingHealthCheckIT.java
@@ -72,7 +72,7 @@ public class KafkaConsumerBadPortSupervisingHealthCheckIT
extends CamelTestSuppo
private MyKafkaHeaderDeserializer deserializer = new
MyKafkaHeaderDeserializer();
@EndpointInject("kafka:" + TOPIC
- +
"?groupId=group1&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&"
+ +
"?groupId=KafkaConsumerBadPortSupervisingHealthCheckIT&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&"
+
"valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&autoCommitIntervalMs=1000&sessionTimeoutMs=30000&autoCommitEnable=true&interceptorClasses=org.apache.camel.component.kafka.MockConsumerInterceptor")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
index 46e304d0613..47fb9a17d77 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
@@ -57,7 +57,7 @@ public class KafkaConsumerFullIT extends
BaseEmbeddedKafkaTestSupport {
private MyKafkaHeaderDeserializer deserializer = new
MyKafkaHeaderDeserializer();
@EndpointInject("kafka:" + TOPIC
- +
"?groupId=group1&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&"
+ +
"?groupId=KafkaConsumerFullIT&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&"
+
"valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&autoCommitIntervalMs=1000&sessionTimeoutMs=30000&autoCommitEnable=true&interceptorClasses=org.apache.camel.component.kafka.MockConsumerInterceptor")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
index bfac711c265..a3c061571ec 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
@@ -77,7 +77,7 @@ public class KafkaConsumerHealthCheckIT extends
CamelTestSupport {
private MyKafkaHeaderDeserializer deserializer = new
MyKafkaHeaderDeserializer();
@EndpointInject("kafka:" + TOPIC
- +
"?groupId=group1&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&"
+ +
"?groupId=KafkaConsumerHealthCheckIT&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&"
+
"valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&autoCommitIntervalMs=1000&sessionTimeoutMs=30000&autoCommitEnable=true&interceptorClasses=org.apache.camel.component.kafka.MockConsumerInterceptor")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
index 6ad1dba93ce..b18448c5be8 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
@@ -42,7 +42,7 @@ public class KafkaConsumerIdempotentIT extends
KafkaConsumerIdempotentTestSuppor
= new KafkaIdempotentRepository("TEST_IDEMPOTENT",
getBootstrapServers());
@EndpointInject("kafka:" + TOPIC
- + "?groupId=group2&autoOffsetReset=earliest"
+ +
"?groupId=KafkaConsumerIdempotentIT&autoOffsetReset=earliest"
+
"&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&autoCommitIntervalMs=1000&sessionTimeoutMs=30000&autoCommitEnable=true"
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java
index 2e80a8d23b7..0f0faca268a 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java
@@ -37,7 +37,7 @@ public class KafkaConsumerIdempotentWithCustomSerializerIT
extends KafkaConsumer
= new KafkaIdempotentRepository("TEST_IDEMPOTENT",
getBootstrapServers());
@EndpointInject("kafka:" + TOPIC
- + "?groupId=group2&autoOffsetReset=earliest"
+ +
"?groupId=KafkaConsumerIdempotentWithCustomSerializerIT&autoOffsetReset=earliest"
+
"&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&headerDeserializer=#class:org.apache.camel.component.kafka.integration.CustomHeaderDeserializer"
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java
index 4a5f9ff685f..28764701875 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java
@@ -37,7 +37,7 @@ public class KafkaConsumerIdempotentWithProcessorIT extends
KafkaConsumerIdempot
= new KafkaIdempotentRepository("TEST_IDEMPOTENT",
getBootstrapServers());
@EndpointInject("kafka:" + TOPIC
- + "?groupId=group2&autoOffsetReset=earliest"
+ +
"?groupId=KafkaConsumerIdempotentWithProcessorIT&autoOffsetReset=earliest"
+
"&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&autoCommitIntervalMs=1000&sessionTimeoutMs=30000&autoCommitEnable=true"
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java
index a178095e280..c48c58e341b 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java
@@ -38,7 +38,8 @@ public class KafkaConsumerTopicIsPatternIT extends
BaseEmbeddedKafkaTestSupport
public static final String TOPIC = "vess123d";
public static final String TOPIC_PATTERN = "v.*d";
- @EndpointInject("kafka:" + TOPIC_PATTERN +
"?topicIsPattern=true&groupId=group1&autoOffsetReset=earliest"
+ @EndpointInject("kafka:" + TOPIC_PATTERN
+ +
"?topicIsPattern=true&groupId=KafkaConsumerTopicIsPatternIT&autoOffsetReset=earliest"
+
"&autoCommitIntervalMs=1000&sessionTimeoutMs=30000&autoCommitEnable=true&interceptorClasses=org.apache.camel.component.kafka.MockConsumerInterceptor&metadataMaxAgeMs=1000")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerUnresolvableHealthCheckIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerUnresolvableHealthCheckIT.java
index c0395ec7f6c..e4fb1893133 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerUnresolvableHealthCheckIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerUnresolvableHealthCheckIT.java
@@ -70,7 +70,7 @@ public class KafkaConsumerUnresolvableHealthCheckIT extends
CamelTestSupport {
private MyKafkaHeaderDeserializer deserializer = new
MyKafkaHeaderDeserializer();
@EndpointInject("kafka:" + TOPIC
- +
"?groupId=group1&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&"
+ +
"?groupId=KafkaConsumerUnresolvableHealthCheckIT&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&"
+
"valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&autoCommitIntervalMs=1000&sessionTimeoutMs=30000&autoCommitEnable=true&interceptorClasses=org.apache.camel.component.kafka.MockConsumerInterceptor")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java
index 16d7229aac9..a74c013a514 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java
@@ -34,7 +34,7 @@ public class KafkaConsumerAsyncCommitIT extends
BaseManualCommitTestSupport {
public static final String TOPIC = "testManualAsyncCommitTest";
@EndpointInject("kafka:" + TOPIC
- +
"?groupId=group1&sessionTimeoutMs=30000&autoCommitEnable=false"
+ +
"?groupId=KafkaConsumerAsyncCommitIT&sessionTimeoutMs=30000&autoCommitEnable=false"
+
"&allowManualCommit=true&autoOffsetReset=earliest&kafkaManualCommitFactory=#class:org.apache.camel.component.kafka.consumer.DefaultKafkaManualAsyncCommitFactory")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerNoopCommitIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerNoopCommitIT.java
index a1daccb40df..199ff0fc88e 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerNoopCommitIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerNoopCommitIT.java
@@ -35,7 +35,7 @@ public class KafkaConsumerNoopCommitIT extends
BaseManualCommitTestSupport {
public static final String TOPIC = "testManualNoopCommitTest";
@EndpointInject("kafka:" + TOPIC
- +
"?groupId=group1&sessionTimeoutMs=30000&autoCommitEnable=false"
+ +
"?groupId=KafkaConsumerNoopCommitIT&sessionTimeoutMs=30000&autoCommitEnable=false"
+
"&allowManualCommit=true&autoOffsetReset=earliest&metadataMaxAgeMs=1000")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerSyncCommitIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerSyncCommitIT.java
index a6e4cddb173..3032bf6ea5e 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerSyncCommitIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerSyncCommitIT.java
@@ -34,7 +34,7 @@ public class KafkaConsumerSyncCommitIT extends
BaseManualCommitTestSupport {
public static final String TOPIC = "testManualCommitSyncTest";
@EndpointInject("kafka:" + TOPIC
- +
"?groupId=group1&sessionTimeoutMs=30000&autoCommitEnable=false"
+ +
"?groupId=KafkaConsumerSyncCommitIT&sessionTimeoutMs=30000&autoCommitEnable=false"
+
"&allowManualCommit=true&autoOffsetReset=earliest&kafkaManualCommitFactory=#class:org.apache.camel.component.kafka.consumer.DefaultKafkaManualCommitFactory")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/pause/KafkaPausableConsumerCircuitBreakerIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/pause/KafkaPausableConsumerCircuitBreakerIT.java
index 89501aa7c5e..7fd3ab4817c 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/pause/KafkaPausableConsumerCircuitBreakerIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/pause/KafkaPausableConsumerCircuitBreakerIT.java
@@ -61,7 +61,7 @@ public class KafkaPausableConsumerCircuitBreakerIT extends
BaseEmbeddedKafkaTest
private LongAdder count = new LongAdder();
@EndpointInject("kafka:" + SOURCE_TOPIC
- +
"?groupId=group1&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+ +
"?groupId=KafkaPausableConsumerCircuitBreakerIT&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&autoCommitIntervalMs=1000&sessionTimeoutMs=30000&autoCommitEnable=true&interceptorClasses=org.apache.camel.component.kafka.MockConsumerInterceptor")
private Endpoint from;
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/pause/KafkaPausableConsumerIT.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/pause/KafkaPausableConsumerIT.java
index 369bd194e9f..24b0005c248 100644
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/pause/KafkaPausableConsumerIT.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/pause/KafkaPausableConsumerIT.java
@@ -79,7 +79,7 @@ public class KafkaPausableConsumerIT extends
BaseEmbeddedKafkaTestSupport {
private LongAdder count = new LongAdder();
@EndpointInject("kafka:" + SOURCE_TOPIC
- +
"?groupId=group1&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+ +
"?groupId=KafkaPausableConsumerIT&autoOffsetReset=earliest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&valueDeserializer=org.apache.kafka.common.serialization.StringDeserializer"
+
"&autoCommitIntervalMs=1000&sessionTimeoutMs=30000&autoCommitEnable=true&interceptorClasses=org.apache.camel.component.kafka.MockConsumerInterceptor")
private Endpoint from;
