diff --git a/src/telemetry/backend/service/TelemetryBackendService.py b/src/telemetry/backend/service/TelemetryBackendService.py
index 79a35d343860d19992518c0e8b29e427e5cbbef4..81ef24481cffc70c6b33bbfbf19d57b062729891 100755
--- a/src/telemetry/backend/service/TelemetryBackendService.py
+++ b/src/telemetry/backend/service/TelemetryBackendService.py
@@ -106,7 +106,7 @@ class TelemetryBackendService(GenericGrpcService):
         Method receives collector request and initiates collecter backend.
         """
         # print("Initiating backend for collector: ", collector_id)
-        LOGGER.info("Initiating backend for collector: ", collector_id)
+        LOGGER.info("Initiating backend for collector: {:s}".format(str(collector_id)))
         start_time = time.time()
         while not stop_event.is_set():
             if int(collector['duration']) != -1 and time.time() - start_time >= collector['duration']:            # condition to terminate backend
@@ -165,9 +165,9 @@ class TelemetryBackendService(GenericGrpcService):
         Args: err (KafkaError): Kafka error object.
               msg (Message): Kafka message object.
         """
-        if err: 
-            LOGGER.debug('Message delivery failed: {:}'.format(err))
+        if err:
+            LOGGER.error('Message delivery failed: {:}'.format(err))
             # print(f'Message delivery failed: {err}')
-        else:
-            LOGGER.info('Message delivered to topic {:}'.format(msg.topic()))
-            # print(f'Message delivered to topic {msg.topic()}')
+        #else:
+        #    LOGGER.debug('Message delivered to topic {:}'.format(msg.topic()))
+        #    # print(f'Message delivered to topic {msg.topic()}')