Pre-merge code cleanup and activation of Telemetry RequestListener

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

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):
         """