Telemetry Backend Service

- GenerateRawMetrics() add

src/telemetry/backend/service/TelemetryBackendService.py

@@ -119,7 +119,7 @@ class TelemetryBackendService:
 
     def GenerateCollectorResponse(self, collector_id: str, kpi_id: str, measured_kpi_value: Any):
         """
-        Method to write response on Kafka topic
+        Method to write kpi value on RESPONSE Kafka topic
         """
         producer = self.kafka_producer
         kpi_value : Dict = {
@@ -134,6 +134,22 @@ class TelemetryBackendService:
         )
         producer.flush()
 
+    def GenerateRawMetric(self, metrics: Any):
+        """
+        Method writes raw metrics on VALUE Kafka topic
+        """
+        producer = self.kafka_producer
+        some_metric : Dict = {
+            "some_id"    : metrics
+        }
+        producer.produce(
+            KafkaTopic.VALUE.value,
+            key      = 'raw',
+            value    = json.dumps(some_metric),
+            callback = self.delivery_callback
+        )
+        producer.flush()
+
     def delivery_callback(self, err, msg):
         """
         Callback function to handle message delivery status.