add tts and stt consumers threads

src/bot.py

@@ -39,7 +39,8 @@
 )
 
 import my_cron
-import kafka.kafka_consumer
+import kafka.consumer_tts
+import kafka.consumer_stt
 
 from logs import init_logger
 
@@ -90,14 +91,16 @@ def process(token_):
         auth_in_db(username=sys.argv[2], password=sys.argv[3])
         if token_ == 'bot':
             main(sys.argv[1])
-        elif token_ == 'kafka':
-            kafka.kafka_consumer.main()
+        elif token_ == 'kafka-tts':
+            kafka.consumer_tts.main()
+        elif token_ == 'kafka-stt':
+            kafka.consumer_stt.main()
         else:
             my_cron.main(sys.argv[1])
 
 
 if __name__ == '__main__':
-    tokens = ['bot', 'schedule', 'kafka']
+    tokens = ['bot', 'schedule', 'kafka-tts', 'kafka-stt']
     work_queue = queue.Queue()
     for token in tokens:
         work_queue.put(token)