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 a5e2d45f7..f39f6ab0e 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 @@ -2415,7 +2415,7 @@ public class KafkaBinderTests extends @Test public void testPolledConsumer() throws Exception { KafkaTestBinder binder = getBinder(); - PollableSource inboundBindTarget = new DefaultPollableMessageSource(); + PollableSource inboundBindTarget = new DefaultPollableMessageSource(this.messageConverter); Binding> binding = binder.bindPollableConsumer("pollable", "group", inboundBindTarget, createConsumerProperties()); Map producerProps = KafkaTestUtils.producerProps(embeddedKafka); @@ -2439,7 +2439,7 @@ public class KafkaBinderTests extends @Test public void testPolledConsumerWithDlq() throws Exception { KafkaTestBinder binder = getBinder(); - PollableSource inboundBindTarget = new DefaultPollableMessageSource(); + PollableSource inboundBindTarget = new DefaultPollableMessageSource(this.messageConverter); ExtendedConsumerProperties properties = createConsumerProperties(); properties.setMaxAttempts(2); properties.setBackOffInitialInterval(0);