Storm项目开发纪要

1、POM引用storm-core和javax.servlet-api这两个组件,如果本地模式跑拓扑,要把<scope>provided</scope>去掉;如果远程发布运行,要添加上。

2、KafkaSpout对应的Bolt在成功处理完tuple之后,一定要记得调用collector.ack()方法,否则会导致KafkaSpout误以为Spout处理失败,相同的消息重复消费。

3、本地运行良好的new ClassPathXmlApplicationContext(); 一旦发布到集群就报找不到XML里面的声明tld文件,最后放弃了使用Spring

原文地址:https://www.cnblogs.com/shuada/p/8810777.html