2023全国大学生数学建模竞赛C题省一论文(仅供学习参考)

对消费者代码进行修改，增加异常处理，使其跳过旧消息。异常处理的好处，同时也能解决由于数据中可能存在的错误格式的数据不能处理的报错。在启动kafka集群之前检查kafka集群文件是否还有为消费的消息文件，将其删除。换一个新的topic。