From 46ae27f7b349796d3807be195a637356a5732b08 Mon Sep 17 00:00:00 2001 From: Aleksey Veresov Date: Tue, 10 Dec 2024 12:34:29 +0100 Subject: [PATCH] Fix kafka topic validation --- python/hopsworks_common/kafka_topic.py | 5 ----- 1 file changed, 5 deletions(-) diff --git a/python/hopsworks_common/kafka_topic.py b/python/hopsworks_common/kafka_topic.py index c056917b7..0bf3e65df 100644 --- 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