SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix the failing test

Browse Source 
The test was failing due to wrong broker address.
This commit is contained in:
Soby Chacko
2020-04-16 12:33:00 -04:00
parent 85663ebea7
commit 1bf1393c6e
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java
View File

@@ -870,8 +870,7 @@ public class KafkaBinderTests extends
public void testDlqWithProducerPropertiesSetAtBinderLevel()
throws Exception {
KafkaBinderConfigurationProperties binderConfiguration = new KafkaBinderConfigurationProperties(
new TestKafkaProperties());
KafkaBinderConfigurationProperties binderConfiguration = createConfigurationProperties();
Map<String, String> consumerProps = new HashMap<>();
consumerProps.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
@@ -896,9 +895,9 @@ public class KafkaBinderTests extends
DirectChannel moduleInputChannel = createBindableChannel("input",
createConsumerBindingProperties(consumerProperties));
Binding<MessageChannel> producerBinding = binder.bindProducer("foo.bar-x",
Binding<MessageChannel> producerBinding = binder.bindProducer("foo.bar",
moduleOutputChannel, outputBindingProperties.getProducer());
Binding<MessageChannel> consumerBinding = binder.bindConsumer("foo.bar-x",
Binding<MessageChannel> consumerBinding = binder.bindConsumer("foo.bar",
"tdwcapsabl", moduleInputChannel, consumerProperties);
// Let the consumer actually bind to the producer before sending a msg
@@ -913,7 +912,7 @@ public class KafkaBinderTests extends
dlqConsumerProperties.setMaxAttempts(1);
Binding<MessageChannel> dlqConsumerBinding = binder.bindConsumer(
"error.foo.bar-x." + "tdwcapsabl", null, dlqChannel,
"error.foo.bar." + "tdwcapsabl", null, dlqChannel,
dlqConsumerProperties);
binderBindUnbindLatency();