kafka中删除topic问题
marked for deletion 网上一片文章说在server.properties里配置delete.topic.enable=true 我没找到这句  就自己添加上去了  但是不起…
] ERROR backtype.storm.util
("Worker died") at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:325) [storm-core-0.9.6.jar:0.9.6] at clojure.lang.RestFn.invoke(…
storm的bol分发问题
小弟现在想做的是从kafka的topic中获取数据,通过第一个bolt将数据存入hbase并将数据emit至第二个bolt,在第二个bolt中将数据处理后存放至redis。 问…
- 共 1 页
- 1