mindol1004/spring-cloud-stream-binder-kafka
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test cleanup

Browse Source
This commit is contained in:
Soby Chacko
2016-10-18 19:45:44 -04:00
parent 275f5cbb8e
commit acb1c60216
1 changed files with 0 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1013,8 +1013,6 @@ public abstract class KafkaBinderTests extends PartitionCapableBinderTests<Abstr
Binding<MessageChannel> producerBinding = binder.bindProducer(testTopicName, output,
createProducerProperties());
waitUntilTopicCreated(getZkUtils(configurationProperties), testTopicName, 5000);
String testPayload = "foo1-" + UUID.randomUUID().toString();
output.send(new GenericMessage<>(testPayload.getBytes()));
@@ -1027,21 +1025,6 @@ public abstract class KafkaBinderTests extends PartitionCapableBinderTests<Abstr
consumerBinding.unbind();
}
private void waitUntilTopicCreated(ZkUtils zkUtils, String testTopicName, int timeoutInMillis) throws Exception {
int partitionSize = 0;
long currentTimeMillis = System.currentTimeMillis();
do {
try {
partitionSize = invokePartitionSize(testTopicName, zkUtils);
Thread.sleep(100);
}
catch (Exception e) {
//falls through
}
}
while (partitionSize == 0 && (currentTimeMillis + timeoutInMillis) > System.currentTimeMillis());
}
@Test
@SuppressWarnings("unchecked")
public void testAutoConfigureTopicsDisabledSucceedsIfTopicExisting() throws Exception {