Kafka-Storm-Conscomp:用于计算和存储美国消费者投诉数据的滚动统计数据的 kafka 风暴拓扑

Kafka-Storm-Conscomp 拓扑 一个 kafka 事件生产者和一个风暴拓扑，用于处理来自 kafka 的事件并将数据存储到 MongoDB。 kafka 生产者读取 csv 文件并将美国消费者投诉事件发送给当地的 kafka 经纪人。 Storm 拓扑从 kafka 代理获取事件，转换事件以进行处理，对每个兼容类型子类型的事件进行计数，然后计算每个投诉类型子类型的滚动统计信息，最后将统计信息持久化到本地 MongoDB 实例。 对于每个项目，请下载最新版本的 maven 以从命令行运行 mvn 命令，或者将其作为 maven 项目导入您的 IDE（前提是存在 maven 插件）。 如果您从命令行运行，请运行mvn clean install和mvn eclipse:eclipse ，然后在您的 IDE 中导入项目。 需要在本地机器上完成以下设置才能运行这些项目：