fix

logicalclocks · Jan 29, 2024 · 8e8b8c6 · 8e8b8c6
1 parent c82b552
commit 8e8b8c6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/hopsworks/core/kafka_api.py b/python/hopsworks/core/kafka_api.py
@@ -364,7 +364,7 @@ def get_default_config(self):
             constants.KAFKA_CONSUMER_CONFIG.GROUP_ID_CONFIG: "my-group-id",
             constants.KAFKA_SSL_CONFIG.SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG: "none",
         }
-
+        _client = client.get_instance()
         if type(_client) == Client:
             config[constants.KAFKA_PRODUCER_CONFIG.BOOTSTRAP_SERVERS_CONFIG] = ",".join(
                 [