Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-118: Update to Spring Kafka 1.0 BUILD-SNAPSHOT

Browse Source 
Fixes #118
This commit is contained in:
Gary Russell
2016-05-13 15:35:05 -04:00
committed by Artem Bilan
parent caae6487e6
commit 66e0772da0
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java
View File

@@ -80,7 +80,7 @@ public class MessageDrivenAdapterTests {
ProducerFactory<Integer, String> pf = new DefaultKafkaProducerFactory<Integer, String>(senderProps);
KafkaTemplate<Integer, String> template = new KafkaTemplate<>(pf);
template.setDefaultTopic("testTopic1");
template.send(1, "foo");
template.sendDefault(1, "foo");
Message<?> received = out.receive(10000);
assertThat(received).isNotNull();