[camel] 02/02: CAMEL-16949: re-enable a few tests that were disabled for a long time

[orpiske]

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 75768eb07c70257aaf6d806299eaa6a10432309e
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Tue Sep 14 19:07:06 2021 +0200

    CAMEL-16949: re-enable a few tests that were disabled for a long time
---
 .../camel/component/kafka/consumer/support/ResumeStrategyFactory.java   | 1 -
 .../apache/camel/component/kafka/integration/KafkaConsumerFullIT.java   | 2 --
 2 files changed, 3 deletions(-)

diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ResumeStrategyFactory.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ResumeStrategyFactory.java
index 7386c88..72fece7 100644
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ResumeStrategyFactory.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ResumeStrategyFactory.java
@@ -36,7 +36,6 @@ public final class ResumeStrategyFactory {
     private ResumeStrategyFactory() {
     }
 
-
     public static ResumeStrategy newResumeStrategy(
             KafkaConsumer<?, ?> consumer, StateRepository<String, String> 
offsetRepository,
             String seekTo) {
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 1cf42fd..f143bd2 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
@@ -137,7 +137,6 @@ public class KafkaConsumerFullIT extends 
BaseEmbeddedKafkaTestSupport {
     }
 
     @Test
-    @Disabled("Currently there is a bug in kafka which leads to an 
uninterruptable thread so a resub take too long (works manually)")
     public void kafkaMessageIsConsumedByCamelSeekedToBeginning() throws 
Exception {
         to.expectedMessageCount(5);
         to.expectedBodiesReceivedInAnyOrder("message-0", "message-1", 
"message-2", "message-3", "message-4");
@@ -166,7 +165,6 @@ public class KafkaConsumerFullIT extends 
BaseEmbeddedKafkaTestSupport {
     }
 
     @Test
-    @Disabled("Currently there is a bug in kafka which leads to an 
uninterruptable thread so a resub take too long (works manually)")
     public void kafkaMessageIsConsumedByCamelSeekedToEnd() throws Exception {
         to.expectedMessageCount(5);
         to.expectedBodiesReceivedInAnyOrder("message-0", "message-1", 
"message-2", "message-3", "message-4");