[camel] branch main updated: camel-kafka: remove bogus sleeps on the test code

[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


The following commit(s) were added to refs/heads/main by this push:
     new d47f2ff  camel-kafka: remove bogus sleeps on the test code
d47f2ff is described below

commit d47f2ff6e6d5427980f38cfd19933eccae7c2153
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Thu Sep 30 13:14:23 2021 +0200

    camel-kafka: remove bogus sleeps on the test code
---
 .../camel/component/kafka/integration/KafkaConsumerFullIT.java       | 5 -----
 .../kafka/integration/KafkaConsumerIdempotentTestSupport.java        | 2 --
 2 files changed, 7 deletions(-)

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 b7dd102..f772423 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
@@ -118,7 +118,6 @@ public class KafkaConsumerFullIT extends 
BaseEmbeddedKafkaTestSupport {
 
         to.assertIsSatisfied(3000);
 
-        Thread.sleep(1000);
         assertEquals(5, 
StreamSupport.stream(MockConsumerInterceptor.recordsCaptured.get(0).records(TOPIC).spliterator(),
 false)
                 .count());
 
@@ -199,10 +198,6 @@ public class KafkaConsumerFullIT extends 
BaseEmbeddedKafkaTestSupport {
 
         context.getRouteController().startRoute("full-it");
 
-        // As wee set seek to end we should not re-consume any messages
-        synchronized (this) {
-            Thread.sleep(1000);
-        }
         to.assertIsSatisfied(3000);
     }
 
diff --git 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
index fed1fee..f42f478 100644
--- 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
+++ 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
@@ -57,8 +57,6 @@ public abstract class KafkaConsumerIdempotentTestSupport 
extends BaseEmbeddedKaf
 
         List<Exchange> exchangeList = mockEndpoint.getReceivedExchanges();
 
-        Thread.sleep(5000);
-
         mockEndpoint.assertIsSatisfied(10000);
 
         assertEquals(size, exchangeList.size());