新版本的streaming-kafka消费 之 kafkaCluster ZKUtils 不能使用问题

基于0.8和0.9的kafka,可以通过kafkacluster.setConsumerOffsets或者zkutils.updatePersistentPath等保存偏移量的,可以1.0以后版本好像都不能用了,有什么好的解决办法吗
已邀请:

刘狗

赞同来自:

可以的,zkutils 还是可以用的,只是没有了kafkacluster

要回复问题请先登录注册


中国HBase技术社区微信公众号:
hbasegroup

欢迎加入HBase生态+Spark社区钉钉大群