[KAFKA-16389] consumer_test.py’s test_valid_assignment fails with new consumer

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 3.7.0
• Fix Version/s: 3.8.0
• Component/s: clients, consumer, system tests
• Labels: kip-848-client-support system-tests
• Assignee: Philip Nee
• Reporter: Kirk True
• Created: 19/Mar/24 23:05
• Updated: 18/Apr/24 17:43
• Resolved: 18/Apr/24 17:43

Description

The following error is reported when running the test_valid_assignment test from consumer_test.py:

 

Traceback (most recent call last):
  File "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", line 186, in _do_run
    data = self.run_test()
  File "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", line 246, in run_test
    return self.test_context.function(self.test)
  File "/usr/local/lib/python3.9/dist-packages/ducktape/mark/_mark.py", line 433, in wrapper
    return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
  File "/opt/kafka-dev/tests/kafkatest/tests/client/consumer_test.py", line 584, in test_valid_assignment
    wait_until(lambda: self.valid_assignment(self.TOPIC, self.NUM_PARTITIONS, consumer.current_assignment()),
  File "/usr/local/lib/python3.9/dist-packages/ducktape/utils/util.py", line 58, in wait_until
    raise TimeoutError(err_msg() if callable(err_msg) else err_msg) from last_exception
ducktape.errors.TimeoutError: expected valid assignments of 6 partitions when num_started 2: [('ducker@ducker05', []), ('ducker@ducker06', [])]

To reproduce, create a system test suite file named test_valid_assignment.yml with these contents:

failures: 
  - 'kafkatest/tests/client/consumer_test.py::AssignmentValidationTest.test_valid_assignment@{"metadata_quorum":"ISOLATED_KRAFT","use_new_coordinator":true,"group_protocol":"consumer","group_remote_assignor":"range"}'

Then set the the TC_PATHS environment variable to include that test suite file.

Issue Links

• links to: GitHub Pull Request #15661