diff --git a/src/common/tools/kafka/Variables.py b/src/common/tools/kafka/Variables.py
index 159d7dac18a6abf3f7ecc0ce258d2b5549c0b2ed..432291c6a1ac0bf43a193d65f72b69f8e56aa574 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: