You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/08/03 16:26:16 UTC
[camel] branch main updated (4d7f82dc392 -> 3783eab4584)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 4d7f82dc392 Errors in Unit-tests for camel-jetty component are solved
new 9c40842514d (chores) camel-kafka: avoid reusing the group ID
new 876622f64e6 (chores) camel-kafka: replace invalid timeout option
new 3783eab4584 (chores) camel-kafka: ensure poll runs shortly
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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(-)
[camel] 03/03: (chores) camel-kafka: ensure poll runs shortly
Posted by or...@apache.org.
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 3783eab4584b8e42df926af02651d9ab97f7d2b0
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Aug 3 17:09:28 2022 +0200
(chores) camel-kafka: ensure poll runs shortly
The default poll duration is longer than the test execution. If no data is provided, this can cause the test to fail as the next poll would likely happen after the assertion timeout
---
.../component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 398a49eca7f..e88e4209b06 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=KafkaConsumerAsyncCommitIT&autoCommitEnable=false"
+ + "?groupId=KafkaConsumerAsyncCommitIT&pollTimeoutMs=1000&autoCommitEnable=false"
+ "&allowManualCommit=true&autoOffsetReset=earliest&kafkaManualCommitFactory=#class:org.apache.camel.component.kafka.consumer.DefaultKafkaManualAsyncCommitFactory")
private Endpoint from;
[camel] 01/03: (chores) camel-kafka: avoid reusing the group ID
Posted by or...@apache.org.
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 <an...@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;
[camel] 02/03: (chores) camel-kafka: replace invalid timeout option
Posted by or...@apache.org.
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 876622f64e688c2feda251ebd5d4a8352c7d2a60
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Aug 3 17:08:13 2022 +0200
(chores) camel-kafka: replace invalid timeout option
This could cause the client to fail after the test had finished
---
.../component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 a74c013a514..398a49eca7f 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=KafkaConsumerAsyncCommitIT&sessionTimeoutMs=30000&autoCommitEnable=false"
+ + "?groupId=KafkaConsumerAsyncCommitIT&autoCommitEnable=false"
+ "&allowManualCommit=true&autoOffsetReset=earliest&kafkaManualCommitFactory=#class:org.apache.camel.component.kafka.consumer.DefaultKafkaManualAsyncCommitFactory")
private Endpoint from;