在之前的博客中记录,如何在项目storm中把每条记录作为消息发送到kafka消息队列中的。这里讲述如何在storm中消费kafka队列中的消息。为何在项目中两个拓扑文件校验和预处理之间要用kafka消息队列进行数据的暂存仍需要去落实。在之前的博客中记录,如何在项目storm中把每条记录作为消息发送到kafka消息队列中 你的当前访问异常,请进行认证后继续阅读剩余内容。 提交