[kafka] branch 2.6 updated: KAFKA-10235 Fix flaky transactions_test.py (#8981)

[jg...@apache.org]

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

jgus 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 a2f647a  KAFKA-10235 Fix flaky transactions_test.py (#8981)
a2f647a is described below

commit a2f647ac888d3ce59cf8ea58a5922d7a381303ee
Author: Chia-Ping Tsai <ch...@gmail.com>
AuthorDate: Fri Jul 10 00:33:07 2020 +0800

    KAFKA-10235 Fix flaky transactions_test.py (#8981)
    
    Reducing timeout of transaction to clean up the unstable offsets quicker. IN hard_bounce mode, transactional client is killed ungracefully. Hence, it produces unstable offsets which obstructs TransactionalMessageCopier from receiving position of group.
    
    Reviewers: Jun Rao <ju...@gmail.com>
---
 tests/kafkatest/tests/core/transactions_test.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/tests/kafkatest/tests/core/transactions_test.py b/tests/kafkatest/tests/core/transactions_test.py
index d958021..8cd1892 100644
--- a/tests/kafkatest/tests/core/transactions_test.py
+++ b/tests/kafkatest/tests/core/transactions_test.py
@@ -47,7 +47,11 @@ class TransactionsTest(Test):
         self.num_output_partitions = 3
         self.num_seed_messages = 100000
         self.transaction_size = 750
-        self.transaction_timeout = 40000
+        # The timeout of transaction should be lower than the timeout of verification. The transactional message sent by
+        # client may be not correctly completed in hard_bounce mode. The pending transaction (unstable offset) stored by
+        # broker obstructs TransactionMessageCopier from getting offset of partition which is used to calculate
+        # remaining messages after restarting.
+        self.transaction_timeout = 5000
         self.consumer_group = "transactions-test-consumer-group"
 
         self.zk = ZookeeperService(test_context, num_nodes=1)