【Kafka】队列的思想

防止并发写入数据丢失，可以采取队列的模式，即发布订阅者模式。

定义一个并发的list的结构，生产者向list填入数据，消费者从list中取出数据，然后再做业务逻辑处理，这样能保证数据不丢失。

kafka中文教程