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 e96df67de..ea9831778 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
@@ -520,7 +520,7 @@ public class KafkaBinderTests extends
 
 		moduleOutputChannel.send(message);
 
-		Message<?> receivedMessage = receive(dlqChannel, 5);
+		Message<?> receivedMessage = dlqChannel.receive(5000);
 		//Ensure that we didn't receive anything on DLQ because of serializer config missing
 		//on dlq producer while native Decoding is enabled.
 		assertThat(receivedMessage).isNull();