From 66e0772da02daff58df21b039816ac52c94f80a8 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 13 May 2016 15:35:05 -0400 Subject: [PATCH] GH-118: Update to Spring Kafka 1.0 BUILD-SNAPSHOT Fixes #118 --- .../integration/kafka/inbound/MessageDrivenAdapterTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java index 2d10594f20..7937740c21 100644 --- a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java +++ b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java @@ -80,7 +80,7 @@ public class MessageDrivenAdapterTests { ProducerFactory pf = new DefaultKafkaProducerFactory(senderProps); KafkaTemplate template = new KafkaTemplate<>(pf); template.setDefaultTopic("testTopic1"); - template.send(1, "foo"); + template.sendDefault(1, "foo"); Message received = out.receive(10000); assertThat(received).isNotNull();