diff --git a/deploy/kafka.sh b/deploy/kafka.sh
index f8610801130bdfd198e112c8388d9ec7a34fffff..0483bce153b457800c6f7db2ef66685e90118111 100755
--- a/deploy/kafka.sh
+++ b/deploy/kafka.sh
@@ -78,7 +78,7 @@ function kafka_deploy() {
 
 echo "Apache Kafka"
 echo ">>> Checking if Apache Kafka is deployed ... "
-if [ "$KFK_REDEPLOY" = "YES" ]; then
+if [ "$KFK_REDEPLOY" == "YES" ]; then
     echo ">>> Redeploying kafka namespace"
     kafka_deploy
 elif kubectl get namespace "${KFK_NAMESPACE}" &> /dev/null; then
diff --git a/src/telemetry/backend/service/TelemetryBackendService.py b/src/telemetry/backend/service/TelemetryBackendService.py
index bb9f0a3147f1d814a137d0b5338596fe8908d3d4..95662969be4f9191e5f3748490a6bc47167e6243 100755
--- a/src/telemetry/backend/service/TelemetryBackendService.py
+++ b/src/telemetry/backend/service/TelemetryBackendService.py
@@ -50,9 +50,8 @@ class TelemetryBackendService(GenericGrpcService):
                                             'auto.offset.reset'  : 'latest'})
         self.running_threads = {}
 
-    def RunRequestListener(self)->bool:
+    def install_servicers(self):
         threading.Thread(target=self.RequestListener).start()
-        return True
 
     def RequestListener(self):
         """