项目中使用了队列,将从kafka中读取的数据保存到队列中,在开启线程从队列中取出数据,保存到数据库
原文:
https://blog.csdn.net/shirukai/article/details/81021981