This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 70f1013 KAFKA-8033; Wait for NoOffsetForPartitionException in
testFetchInvalidOffset (#9184)
70f1013 is described below
commit 70f10137f998f6948b122717f87ff48006909ce3
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 4d8c160..7625d04 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
