From ffd0c1501f56b84272d5ac69ea0dc795d9d8b13f Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Sun, 16 Mar 2025 12:32:34 +0000
Subject: [PATCH] Common - Kafka tools:
- Added NBI_SOCKETIO_WORKERS channel
---
src/common/tools/kafka/Variables.py | 21 +++++++++++----------
1 file changed, 11 insertions(+), 10 deletions(-)
diff --git a/src/common/tools/kafka/Variables.py b/src/common/tools/kafka/Variables.py
index 159d7dac1..432291c6a 100644
--- a/src/common/tools/kafka/Variables.py
+++ b/src/common/tools/kafka/Variables.py
@@ -47,16 +47,17 @@ class KafkaConfig(Enum):
class KafkaTopic(Enum):
# TODO: Later to be populated from ENV variable.
- TELEMETRY_REQUEST = 'topic_telemetry_request'
- TELEMETRY_RESPONSE = 'topic_telemetry_response'
- RAW = 'topic_raw'
- LABELED = 'topic_labeled'
- VALUE = 'topic_value'
- ALARMS = 'topic_alarms'
- ANALYTICS_REQUEST = 'topic_analytics_request'
- ANALYTICS_RESPONSE = 'topic_analytics_response'
- VNTMANAGER_REQUEST = 'topic_vntmanager_request'
- VNTMANAGER_RESPONSE = 'topic_vntmanager_response'
+ TELEMETRY_REQUEST = 'topic_telemetry_request'
+ TELEMETRY_RESPONSE = 'topic_telemetry_response'
+ RAW = 'topic_raw'
+ LABELED = 'topic_labeled'
+ VALUE = 'topic_value'
+ ALARMS = 'topic_alarms'
+ ANALYTICS_REQUEST = 'topic_analytics_request'
+ ANALYTICS_RESPONSE = 'topic_analytics_response'
+ VNTMANAGER_REQUEST = 'topic_vntmanager_request'
+ VNTMANAGER_RESPONSE = 'topic_vntmanager_response'
+ NBI_SOCKETIO_WORKERS = 'tfs-nbi-socketio'
@staticmethod
def create_all_topics() -> bool:
--
GitLab