From 33c7b42855e3b32a0054a29a716d33ce12c50336 Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Sun, 16 Mar 2025 12:32:53 +0000
Subject: [PATCH] NBI component:
- Added missing comment
---
src/nbi/service/NbiApplication.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/src/nbi/service/NbiApplication.py b/src/nbi/service/NbiApplication.py
index 0ee7c58ef..dee09462c 100644
--- a/src/nbi/service/NbiApplication.py
+++ b/src/nbi/service/NbiApplication.py
@@ -41,6 +41,9 @@ class NbiApplication:
self._app.config['SECRET_KEY'] = SECRET_KEY
self._app.after_request(log_request)
self._api = Api(self._app, prefix=base_url)
+
+ # Configure KafkaManager to enable SocketIO Servers running in different
+ # gunicorn workers to self-coordinate and share sessions.
self._sio_client_manager = socketio.KafkaManager(
url='kafka://{:s}'.format(KafkaConfig.get_kafka_address()),
channel=KafkaTopic.NBI_SOCKETIO_WORKERS.value
--
GitLab