大数据&云计算大数据学习之路大数据,机器学习,人工智能

sparkstreaming +kafka 对offset进行的

2019-03-07  本文已影响4人  大数据修行

使用kafka自身保存offset

Kafka版本0.10.1.1,已默认将消费的offset迁入到了Kafka一个名为__consumer_offsets的Topic中。所以我们读写offset的对象正是这个topic,实际上,一切都已经封装好了,直接调用相关API即可。

image
上一篇 下一篇

猜你喜欢

热点阅读