From 1192825381f7f4ec6c5f87b5dd3d4a82707a402d Mon Sep 17 00:00:00 2001 From: Ilia Zhdanov Date: Thu, 13 Nov 2025 09:30:08 +0300 Subject: [PATCH] Changed partition assignments to None in order to controller would be responsible for assigning replicas to brokers, when new partitions is created --- module_utils/kafka_manager.py | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/module_utils/kafka_manager.py b/module_utils/kafka_manager.py index 6a257262..28d73497 100644 --- a/module_utils/kafka_manager.py +++ b/module_utils/kafka_manager.py @@ -795,24 +795,10 @@ def update_topics_partitions(self, topics): See NewPartitions class for explanations apache/kafka/clients/admin/NewPartitions.java#L53 """ - brokers = [] - for node_id, _, _, _ in self.get_brokers(): - brokers.append(int(node_id)) - brokers_iterator = itertools.cycle(brokers) topics_assignments = [] for topic_name, partitions in topics.items(): - topic, _, _, replicas, _, _ = ( - self.get_partitions_for_topic(topic_name)[0] - ) - total_replica = len(replicas) - old_partition = self.get_total_partitions_for_topic(topic_name) - assignments = [] - for _new_partition in range(partitions - old_partition): - assignment = [] - for _replica in range(total_replica): - assignment.append(next(brokers_iterator)) - assignments.append(assignment) + assignments = None topics_assignments.append( (topic_name, (partitions, assignments)) )