Open white-shiro-bai opened 3 years ago
目前已经解决，其实是因为kafka发送消息是异步发送，然后由于uwsgi进程消失，主进程消亡，子进程同样消亡，设置主进程阻塞，等待子进程完成即可。 future = current_app.kafka_producer.send(topic=kafka_topic, key=key, value=msg_str.encode()) result = future.get(timeout=10)
future = current_app.kafka_producer.send(topic=kafka_topic, key=key, value=msg_str.encode()) result = future.get(timeout=10)
目前已经解决，其实是因为kafka发送消息是异步发送，然后由于uwsgi进程消失，主进程消亡，子进程同样消亡，设置主进程阻塞，等待子进程完成即可。
future = current_app.kafka_producer.send(topic=kafka_topic, key=key, value=msg_str.encode()) result = future.get(timeout=10)