Loading src/nbi/service/NbiApplication.py +3 −0 Original line number Diff line number Diff line Loading @@ -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 Loading Loading
src/nbi/service/NbiApplication.py +3 −0 Original line number Diff line number Diff line Loading @@ -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 Loading