squah-confluent commented on code in PR #21722:
URL: https://github.com/apache/kafka/pull/21722#discussion_r2940317240
##########
tests/kafkatest/services/kafka/kafka.py:
##########
@@ -309,6 +311,18 @@ def __init__(self, context, num_nodes, zk,
security_protocol=SecurityConfig.PLAI
consumer_group_migration_policy = context.globals.get(arg_name)
self.consumer_group_migration_policy = consumer_group_migration_policy
+ # Set enable_assignment_batching based on context and arguments.
+ # If not specified, defaults to true.
+ if enable_assignment_batching is None:
+ arg_name = 'enable_assignment_batching'
+ if context.injected_args is not None:
+ enable_assignment_batching =
context.injected_args.get(arg_name)
+ if enable_assignment_batching is None:
+ enable_assignment_batching = context.globals.get(arg_name)
+ if enable_assignment_batching is None:
+ enable_assignment_batching = True
Review Comment:
It'll be enabled by default everywhere in the system tests since it's
enabled by default in the kafka config definition.
--
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]
