企业公告topic调整

comData/noticeReport/证监会-公告.py

-
+
@@ -353,7 +353,7 @@ def GetContent(pdf_url, pdf_name, social_code, year, pub_time, start_time,com_na
     # 将相应字段通过kafka传输保存
     try:
         producer = KafkaProducer(bootstrap_servers=['114.115.159.144:9092'])
-        kafka_result = producer.send("researchReportTopicaaaas", json.dumps(dic_news, ensure_ascii=False).encode('utf8'))
+        kafka_result = producer.send("researchReportTopic", json.dumps(dic_news, ensure_ascii=False).encode('utf8'))
 
         print(kafka_result.get(timeout=10))