kafka storm 整合，提交任务失败【java吧】

java吧关注：1,295,663贴子：12,832,172

5回复贴，共1页

kafka storm 整合，提交任务失败

提交Topology的jar文件后报错：Unable to get offset lags for kafka. Reason: java.lang.NullPointerException at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.getOffsetLags(KafkaOffsetLagUtil.java:272) at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.main(KafkaOffsetLagUtil.java:124)
在本地模式是可以的，zkRoot也设置了

送TA礼物

IP属地:上海

1楼2018-05-22 17:55回复

估计这么看空指针，神仙也看不出来，调试呀

来自Android客户端3楼2018-05-22 18:20

不感兴趣

开通SVIP免广告

这个问题楼主有解决么？遇到同样的问题，请不吝赐教

4楼2018-07-25 16:31

可能是你的bolt没有调用collector.ack(tuple);，会导致KafkaSpout一直认为发送失败，重新发送，并且不会在zk记录偏移量。
解决方法：
1.显式调用collector.ack(tuple);
2.继承BaseBasicBolt，该类会自动调用collector.ack(tuple)。

IP属地:江苏

5楼2018-07-28 18:52

扫二维码下载贴吧客户端

下载贴吧APP
看高清直播、视频！

贴吧热议榜

5回复贴，共1页

<返回java吧

发表回复

发贴请遵守贴吧协议及“七条底线”贴吧投诉

内容:

使用签名档查看全部

发表

保存至快速回贴

日	一	二	三	四	五	六

kafka storm 整合，提交任务失败

登录百度账号

扫二维码下载贴吧客户端