防止并发写入数据丢失,可以采取队列的模式,即发布订阅者模式。 定义一个并发的list的结构,生产者向list填入数据,消费者从list中取出数据,然后再做业务逻辑处理,这样能保证数据不丢失。 kafka中文教程