消息关闭
    暂无新消息!
使用kafka低阶读取模式编写streaming任务,每个rdd结束后均将offset 提交到zookeeper中,使用如下方法提交:
 ZkUtils.updatePersistentPath(zkClient, zkPath, osr.untilOffset.toString)

streaming运行未报错,但是到zookeeper 相应的目录中查看,却offset值前面有些乱码,不知道是什么原因?

3个回答

︿ 2
我也踩到这个坑了,最后还是在别的地方搜到的
http://www.aboutyun.com/thread-20427-1-1.html
︿ 2
楼主你好,我现在也遇到同样的问题,想用kafka offsets monitor监控,但是发现zookeeper中有乱码,请问你的问题解决了么?谢谢