diff --git a/src/nbi/service/NbiApplication.py b/src/nbi/service/NbiApplication.py index 0ee7c58ef7766a2d7c3b3c117361f4aca678b86e..dee09462c3b48a5c5877ed7df4f6d4b07c95359c 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