Fix kafka topic validation

logicalclocks · Dec 10, 2024 · 46ae27f · 46ae27f
1 parent 0282781
commit 46ae27f
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/python/hopsworks_common/kafka_topic.py b/python/hopsworks_common/kafka_topic.py
@@ -84,11 +84,6 @@ def _validate_topic_config(cls, name, num_replicas, num_partitions):
                         )
                     )
                     num_partitions = KAFKA_TOPIC.NUM_PARTITIONS
-            else:
-                if num_replicas is not None or num_partitions is not None:
-                    raise ValueError(
-                        "Number of replicas or partitions cannot be changed in existing kafka topics."
-                    )
         elif name is None or name == KAFKA_TOPIC.NONE:
             num_replicas = None
             num_partitions = None