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

INTEXT-123-124-125: Increase maxWait for tests

Browse Source
This commit is contained in:
Artem Bilan
2015-01-16 19:51:25 +02:00
committed by Artem Bilan
parent 6acf985cc1
commit 5989e618ed
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-integration-kafka/src/test/java/org/springframework/integration/kafka/listener/DefaultConnectionTests.java
View File

@@ -49,7 +49,8 @@ public class DefaultConnectionTests extends AbstractBrokerTests {
@Test
public void testFetchPartitionMetadata() throws Exception {
createTopic(TEST_TOPIC, 1, 1, 1);
Connection brokerConnection = new DefaultConnection(getKafkaRule().getBrokerAddresses().get(0), "client", 64*1024, 3000, 1, 100);
Connection brokerConnection =
new DefaultConnection(getKafkaRule().getBrokerAddresses().get(0), "client", 64*1024, 3000, 1, 10000);
Partition partition = new Partition(TEST_TOPIC, 0);
Result<Long> result = brokerConnection.fetchInitialOffset(-1, partition);
Assert.assertEquals(0, result.getErrors().size());
@@ -62,7 +63,8 @@ public class DefaultConnectionTests extends AbstractBrokerTests {
createTopic(TEST_TOPIC, 1, 1, 1);
Producer<String, String> producer = createStringProducer(0);
producer.send( createMessages(10, TEST_TOPIC));
Connection brokerConnection = new DefaultConnection(getKafkaRule().getBrokerAddresses().get(0), "client", 64*1024, 3000, 1, 100);
Connection brokerConnection =
new DefaultConnection(getKafkaRule().getBrokerAddresses().get(0), "client", 64*1024, 3000, 1, 10000);
Partition partition = new Partition(TEST_TOPIC, 0);
FetchRequest fetchRequest = new FetchRequest(partition, 0L, 1000);
Result<KafkaMessageBatch> result = brokerConnection.fetch(fetchRequest);
@@ -84,7 +86,8 @@ public class DefaultConnectionTests extends AbstractBrokerTests {
createTopic(TEST_TOPIC, 1, 1, 1);
Producer<String, String> producer = createStringProducer(1);
producer.send( createMessages(10, TEST_TOPIC));
Connection brokerConnection = new DefaultConnection(getKafkaRule().getBrokerAddresses().get(0), "client", 64*1024, 3000, 1, 100);
Connection brokerConnection =
new DefaultConnection(getKafkaRule().getBrokerAddresses().get(0), "client", 64*1024, 3000, 1, 10000);
Partition partition = new Partition(TEST_TOPIC, 0);
FetchRequest fetchRequest = new FetchRequest(partition, 0L, 1000);
Result<KafkaMessageBatch> result = brokerConnection.fetch(fetchRequest);
@@ -106,7 +109,8 @@ public class DefaultConnectionTests extends AbstractBrokerTests {
createTopic(TEST_TOPIC, 1, 1, 1);
Producer<String, String> producer = createStringProducer(2);
producer.send( createMessages(10, TEST_TOPIC));
Connection brokerConnection = new DefaultConnection(getKafkaRule().getBrokerAddresses().get(0), "client", 64*1024, 3000, 1, 100);
Connection brokerConnection =
new DefaultConnection(getKafkaRule().getBrokerAddresses().get(0), "client", 64*1024, 3000, 1, 10000);
Partition partition = new Partition(TEST_TOPIC, 0);
FetchRequest fetchRequest = new FetchRequest(partition, 0L, 1000);
Result<KafkaMessageBatch> result = brokerConnection.fetch(fetchRequest);