From 46c42478a0982023344313d0dc949356048f9864 Mon Sep 17 00:00:00 2001 From: David Mao Date: Fri, 30 Oct 2020 18:01:26 -0700 Subject: [PATCH] Update message validator format for KIP-431 --- tests/kafkatest/tests/core/group_mode_transactions_test.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/tests/kafkatest/tests/core/group_mode_transactions_test.py b/tests/kafkatest/tests/core/group_mode_transactions_test.py index 5763ada5bfda5..141c613730d72 100644 --- a/tests/kafkatest/tests/core/group_mode_transactions_test.py +++ b/tests/kafkatest/tests/core/group_mode_transactions_test.py @@ -153,8 +153,9 @@ def valid_value_and_partition(msg): """ try: splitted_msg = msg.split('\t') - tuple = [int(splitted_msg[0]), int(splitted_msg[1])] - return tuple + value = int(splitted_msg[1]) + partition = int(splitted_msg[0].split(":")[1]) + return [value, partition] except ValueError: raise Exception("Unexpected message format (expected a tab separated [value, partition] tuple). Message: %s" % (msg))