From e1e46226d5c22c7a9d01048c6c4a409fae0ac79b Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Mon, 26 Aug 2019 12:16:58 -0400 Subject: [PATCH] Fixing a test race condition The test testDlqWithNativeSerializationEnabledOnDlqProducer fails on CI occasionally. Adding a sleep of 1 second to give the retrying mechanism enough time to complete. --- .../cloud/stream/binder/kafka/KafkaBinderTests.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java index d7d3d5b56..d8d9dba93 100644 --- a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java +++ b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java @@ -544,6 +544,8 @@ public class KafkaBinderTests extends Message receivedMessage = receive(dlqChannel, 5); assertThat(receivedMessage).isNotNull(); assertThat(receivedMessage.getPayload()).isEqualTo("foo".getBytes()); + //Adding a 1 second sleep to give the retrying enough time to complete. + Thread.sleep(1000); assertThat(handler.getInvocationCount()) .isEqualTo(consumerProperties.getMaxAttempts()); assertThat(receivedMessage.getHeaders()