storm链接kafka时需要导入kafka、storm和storm链接kafka的jar包外，还需要这些jar包的支持

风暴卡夫卡 风暴拓扑将风暴与Kafka和Elasticsearch集成 该Storm拓扑使用Kafka Spout读取来自Kafka的消息，并使用Bolt将从Kafka读取的传入消息解析为JSON消息。 然后将已解析的JSON消息加载到Elastic搜索中以使用Kibana进行仪表板和分析 该项目的前提条件：Zookeeper安装Kafka Broker Storm安装并启动Nimbus，Supervisor，Logviewer和UI Elastic search Kibana（用于仪表板） 设置：安装完上述工具集后，将maven项目下载到本地工作区中并构建一个jar 执行：风暴罐/Storm-Kafka-ES-Integration/target/StormKafkaESIntegration-0.0.1-SNAPSHOT-jar-with-dependencies.jar com.

在开发时候导入这个包和storm、kafka的核心包即可

此项目不再维护 有关最新信息，请参阅 。 Storm-kafka-hdfs-starter 提供使用 KafkaSpout 和 HdfsBolt 的示例

maven搭建的storm+kafka+redis+mysql实例程序，导入后下载maven库可运行

storm流式计算的介绍，包括kafka、redis的介绍，包含日志系统、电商交易系统的文档。

该文档是storm与kafka整合的工具包，可以直接进行kafka与storm对接，直接调用接口即可

使用log4j生成日志信息，使用flume对日志进行监控并采集，将采集到的数据放到kafka中使用storm对数据进行清洗和标准化，FilterBolt对error，warning等单词进行过滤，NotifyBolt触发规则之后，会往用户的邮箱发送邮件并发送短信通知用户。

大数据实时数据采集架构

框架为Logstash+storm+kafka 视频很详细，关于Storm的整合多个框架里面也有！包括源码！！！！