root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

HOTFIX: fix log message in version probing system test (#8341) 

Reviewer: Matthias J. Sax <matthias@confluent.io>
This commit is contained in:
A. Sophie Blee-Goldman 2020-03-24 21:46:37 -07:00 committed by GitHub
parent b5409b9c04
commit e1cbefef60
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
View File

@ -526,6 +526,8 @@ public class StreamThread extends Thread {
try { try {
runOnce(); runOnce();
if (assignmentErrorCode.get() == AssignorError.REBALANCE_NEEDED.code()) { if (assignmentErrorCode.get() == AssignorError.REBALANCE_NEEDED.code()) {
log.info("Detected that the assignor requested a rebalance. Rejoining the consumer group to " +
"trigger a new rebalance.");
assignmentErrorCode.set(AssignorError.NONE.code()); assignmentErrorCode.set(AssignorError.NONE.code());
mainConsumer.enforceRebalance(); mainConsumer.enforceRebalance();
} }

2
tests/kafkatest/tests/streams/streams_upgrade_test.py
View File

@ -539,7 +539,7 @@ class StreamsUpgradeTest(Test):
timeout_sec=60, timeout_sec=60,
err_msg="Never saw output 'Upgrade metadata to version 8' on" + str(second_other_node.account)) err_msg="Never saw output 'Upgrade metadata to version 8' on" + str(second_other_node.account))
log_monitor.wait_until("Version probing detected. Rejoining the consumer group to trigger a new rebalance.", log_monitor.wait_until("Detected that the assignor requested a rebalance. Rejoining the consumer group to trigger a new rebalance.",
timeout_sec=60, timeout_sec=60,
err_msg="Could not detect 'Triggering new rebalance' at upgrading node " + str(node.account)) err_msg="Could not detect 'Triggering new rebalance' at upgrading node " + str(node.account))