Fix KafkaApi.__init__

logicalclocks · Jul 25, 2024 · ee18a27 · ee18a27
1 parent f5a561e
commit ee18a27
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/hopsworks_common/core/kafka_api.py b/python/hopsworks_common/core/kafka_api.py
@@ -28,8 +28,8 @@
 class KafkaApi:
     def __init__(
         self,
-        project_id,
-        project_name,
+        project_id=None,
+        project_name=None,
     ):
         self._project_id = project_id
         self._project_name = project_name