Skip to content

Commit db0cadd

Browse files
committed
Increase the receive timeout on consumer
1 parent c72255e commit db0cadd

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

tests/src/test/java/com/datastax/oss/pulsar/functions/transforms/tests/AbstractDockerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -557,7 +557,7 @@ private <T> GenericRecord testTransformFunction(
557557
}
558558
producerMessage.send();
559559
}
560-
Message<GenericRecord> message = consumer.receive(30, TimeUnit.SECONDS);
560+
Message<GenericRecord> message = consumer.receive(60, TimeUnit.SECONDS);
561561

562562
if (allowNullMessage && message == null) {
563563
return null;

0 commit comments

Comments
 (0)