chickenchickenlove opened a new pull request, #23366: URL: https://github.com/apache/kafka/pull/23366
### Summary - Fixes test_fencing_static_consumer flakiness by allowing expected-to-fail conflict consumers to start without waiting for all nodes to be simultaneously alive. - Remove unused codes. - Declare return types for better type inference. ### Test Result ``` ================================================================================ SESSION REPORT (ALL TESTS) ducktape version: 0.14.0 session_id: 2026-09-04--002 run time: 5 minutes 51.535 seconds tests run: 8 passed: 8 flaky: 0 failed: 0 ignored: 0 ================================================================================ test_id: kafkatest.tests.client.consumer_test.OffsetValidationTest.test_fencing_static_consumer.num_conflict_consumers=1.fencing_stage=all.metadata_quorum=ISOLATED_KRAFT.group_protocol=classic status: PASS run time: 29.502 seconds -------------------------------------------------------------------------------- test_id: kafkatest.tests.client.consumer_test.OffsetValidationTest.test_fencing_static_consumer.num_conflict_consumers=1.fencing_stage=all.metadata_quorum=ISOLATED_KRAFT.group_protocol=consumer status: PASS run time: 29.419 seconds -------------------------------------------------------------------------------- test_id: kafkatest.tests.client.consumer_test.OffsetValidationTest.test_fencing_static_consumer.num_conflict_consumers=1.fencing_stage=stable.metadata_quorum=ISOLATED_KRAFT.group_protocol=classic status: PASS run time: 30.707 seconds -------------------------------------------------------------------------------- test_id: kafkatest.tests.client.consumer_test.OffsetValidationTest.test_fencing_static_consumer.num_conflict_consumers=1.fencing_stage=stable.metadata_quorum=ISOLATED_KRAFT.group_protocol=consumer status: PASS run time: 1 minute 19.619 seconds -------------------------------------------------------------------------------- test_id: kafkatest.tests.client.consumer_test.OffsetValidationTest.test_fencing_static_consumer.num_conflict_consumers=2.fencing_stage=all.metadata_quorum=ISOLATED_KRAFT.group_protocol=classic status: PASS run time: 30.993 seconds -------------------------------------------------------------------------------- test_id: kafkatest.tests.client.consumer_test.OffsetValidationTest.test_fencing_static_consumer.num_conflict_consumers=2.fencing_stage=all.metadata_quorum=ISOLATED_KRAFT.group_protocol=consumer status: PASS run time: 29.986 seconds -------------------------------------------------------------------------------- test_id: kafkatest.tests.client.consumer_test.OffsetValidationTest.test_fencing_static_consumer.num_conflict_consumers=2.fencing_stage=stable.metadata_quorum=ISOLATED_KRAFT.group_protocol=classic status: PASS run time: 34.358 seconds -------------------------------------------------------------------------------- test_id: kafkatest.tests.client.consumer_test.OffsetValidationTest.test_fencing_static_consumer.num_conflict_consumers=2.fencing_stage=stable.metadata_quorum=ISOLATED_KRAFT.group_protocol=consumer status: PASS run time: 1 minute 25.968 seconds -------------------------------------------------------------------------------- ``` -- 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]
