send message to backend

Author: Zat-Code

deploy/docker-compose.yaml

@@ -13,7 +13,7 @@ services:
     depends_on:
       - zookeeper
     ports:
-      - 29093:29092
+      - 29092:29092
     environment:
       KAFKA_BROKER_ID: 1
       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

src/main.py

@@ -9,18 +9,19 @@ def __init__(self):
 
         self.running = True
 
-        self.producer_thread = ProducerThread("localhost:29093")
+        self.producer_thread = ProducerThread("localhost:29092")
 
-        self.consumer_thread = ConsumerThread("localhost:29093")
-        self.consumer_thread.add_topics("test", self.on_callback_test)
+        self.consumer_thread = ConsumerThread("localhost:29092")
+        self.consumer_thread.add_topics("analyse", self.on_callback_test)
 
         self.consumer_thread.start()
         self.producer_thread.start()
 
 
     def on_callback_test(self, topic, data):
         print("message receive : ", topic, data)
-        print("a")
+
+        self.producer_thread.send("analyse_report", "test")
 
     def run(self):