[kafka] branch 2.6 updated: KAFKA-9509: Increase timeout when consuming records to fix flaky test in MM2 (#8894)

[kk...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kkarantasis pushed a commit to branch 2.6
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.6 by this push:
     new 550ad76  KAFKA-9509: Increase timeout when consuming records to fix flaky test in MM2 (#8894)
550ad76 is described below

commit 550ad76b9580fec757bb7cc47fb86b3691d8f733
Author: showuon <43...@users.noreply.github.com>
AuthorDate: Tue Jun 30 04:22:08 2020 +0800

    KAFKA-9509: Increase timeout when consuming records to fix flaky test in MM2 (#8894)
    
    A simple increase in the timeout of the consumer that verifies that records have been replicated seems to fix the integration tests in `MirrorConnectorsIntegrationTest` that have been failing more often recently.
    
    Reviewers: Ryanne Dolan <ry...@gmail.com>, Sanjana Kaundinya <sk...@gmail.com>, Chia-Ping Tsai <ch...@gmail.com>, Konstantine Karantasis <ko...@confluent.io>
---
 .../apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
index 916c008..169968c 100644
--- a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
+++ b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
@@ -58,7 +58,7 @@ public class MirrorConnectorsIntegrationTest {
 
     private static final int NUM_RECORDS_PRODUCED = 100;  // to save trees
     private static final int NUM_PARTITIONS = 10;
-    private static final int RECORD_TRANSFER_DURATION_MS = 10_000;
+    private static final int RECORD_TRANSFER_DURATION_MS = 20_000;
     private static final int CHECKPOINT_DURATION_MS = 20_000;
 
     private MirrorMakerConfig mm2Config;