This is an automated email from the ASF dual-hosted git repository. rsivaram pushed a commit to branch 2.6 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit fe2e9f572f5fa77f7445cbe84b79ac5dc14cb184 Author: Rajini Sivaram <[email protected]> AuthorDate: Sun Aug 16 10:51:28 2020 +0100 KAFKA-8033; Wait for NoOffsetForPartitionException in testFetchInvalidOffset (#9184) Reviewers: Ismael Juma <[email protected]> --- .../src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala b/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala index 5c7a52a..f61b3c5 100644 --- a/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala +++ b/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala @@ -678,9 +678,10 @@ class PlaintextConsumerTest extends BaseConsumerTest { sendRecords(producer, totalRecords, tp) consumer.assign(List(tp).asJava) - // poll should fail because there is no offset reset strategy set + // poll should fail because there is no offset reset strategy set. + // we fail only when resetting positions after coordinator is known, so using a long timeout. intercept[NoOffsetForPartitionException] { - consumer.poll(Duration.ofMillis(50)) + consumer.poll(Duration.ofMillis(15000)) } // seek to out of range position
