feat:添加Kafka Producer相关功能

main.py

@@ -1,7 +1,9 @@
 from flask import *
 
+import threading
+
 from init import init_all
-from service.init import run_kafka_spark
+from service.producer import run_kafka_producer
 from conf.util import *
 
 # from web import app
@@ -23,9 +25,15 @@ if __name__ == '__main__':
     init_all()
     
     # 运行Kafka与Spark相关
-    run_kafka_spark()
+
+    kafka_producer_t = threading.Thread(target=run_kafka_producer())
+    web_t = threading.Thread(target=app.run(host=conf.get('server', 'listen'), port=conf.get('server', 'port'), debug=conf.get('server', 'debug')))
+    kafka_producer_t.start()
+    web_t.start()
+
+
 
     # 运行Web服务
-    app.run(host=conf.get('server', 'listen'), port=conf.get('server', 'port'), debug=conf.get('server', 'debug'))
+