You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2020/12/23 16:14:11 UTC
[kafka] branch 2.7 updated: KAFKA-10815
EosTestDriver#verifyAllTransactionFinished should break loop if all
partitions are verified (#9706) (#9782)
This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch 2.7
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.7 by this push:
new 39b467f KAFKA-10815 EosTestDriver#verifyAllTransactionFinished should break loop if all partitions are verified (#9706) (#9782)
39b467f is described below
commit 39b467f7f9a28b1277f74710dd41d129e233836d
Author: Chia-Ping Tsai <ch...@gmail.com>
AuthorDate: Thu Dec 24 00:12:48 2020 +0800
KAFKA-10815 EosTestDriver#verifyAllTransactionFinished should break loop if all partitions are verified (#9706) (#9782)
Reviewers: Matthias J. Sax <mj...@apache.org>
---
streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java b/streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java
index 9f24720..18822d3 100644
--- a/streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java
+++ b/streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java
@@ -598,7 +598,7 @@ public class EosTestDriver extends SmokeTestUtil {
final long maxWaitTime = System.currentTimeMillis() + MAX_IDLE_TIME_MS;
try (final KafkaConsumer<byte[], byte[]> consumerUncommitted = new KafkaConsumer<>(consumerProps)) {
- while (System.currentTimeMillis() < maxWaitTime) {
+ while (!partitions.isEmpty() && System.currentTimeMillis() < maxWaitTime) {
consumer.seekToEnd(partitions);
final Map<TopicPartition, Long> topicEndOffsets = consumerUncommitted.endOffsets(partitions);