[kafka] 02/02: KAFKA-8033; Wait for NoOffsetForPartitionException in testFetchInvalidOffset (#9184)

[rs...@apache.org]

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 <ra...@googlemail.com>
AuthorDate: Sun Aug 16 10:51:28 2020 +0100

    KAFKA-8033; Wait for NoOffsetForPartitionException in testFetchInvalidOffset (#9184)
    
    Reviewers: Ismael Juma <is...@juma.me.uk>
---
 .../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