Harsh-99999 opened a new pull request, #23299: URL: https://github.com/apache/kafka/pull/23299
## Problem `verify_running()` opens a log monitor before calling `processor.start()`. The startup path can open another monitor on the same log file while waiting for a different startup message. When the Streams client reaches `RUNNING` quickly, the expected message can be missed between the two monitors, resulting in intermittent system test failures. ## Fix Call `processor.start_node(node)` before opening the log monitor. This avoids the nested monitor race and ensures the monitor is established only after node startup has completed. ## Testing The affected test was run repeatedly: `StreamsStaticMembershipTest.test_fencing_static_streams_member` Before the fix: * 1/5 isolated runs failed. After the fix: * 5/5 isolated runs passed. The change is limited to `tests/kafkatest/tests/streams/utils/util.py`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
