This is an automated email from the ASF dual-hosted git repository.
dajac 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 ee1aa07 MINOR: Fix group_mode_transactions_test (#9538)
ee1aa07 is described below
commit ee1aa070367829e7670b6ca705398e82c6c6514e
Author: David Mao <[email protected]>
AuthorDate: Sat Oct 31 07:43:13 2020 -0500
MINOR: Fix group_mode_transactions_test (#9538)
KIP-431 (#9099) changed the format of console consumer output to
`Partition:$PARTITION\t$VALUE` whereas previously the output format was
`$VALUE\t$PARTITION`. This PR updates the message verifier to accommodate the
updated console consumer output format.
---
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 5763ada..141c613 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 @@ class GroupModeTransactionsTest(Test):
"""
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))
