概述
有很多小伙伴不知道Kafka的偏移量说的到底是什么，导致使用它的时候迷迷糊糊的，现在我给大家用最简单的方式说说这个东西到底是什么
首先偏移量是一个比较官方的说法，其实它就是两个数字，一个表示这当前数据消费的位置，另一个代表着数据量最大位置，我在网上随便找了一个kafka0.10以后自带的偏移量维护脚本所展示的信息，大家看一下，让大家先从最源头的kafka端看一下偏移量到底长的是什么样的字
如上图展示的信息当中详细的展示了消费者组对应一个主题下所有分区的偏移量，以及对应的消费者线程，其中我们重点看CURRENT-OFFSET和LOG-END-OFFSET
CURRENT-OFFSET指的就是现在对应的消费者线程消费到了多少条数据，而LOG-END-OFFSET是该分区总计有多少条数据
而我们通常在使用kafka的时候，要关注偏移量常常出现在要手动维护的时候，如果是自动维护那么根本不用我们操行，kafka自己和其他框架融合的时候早就把一切考虑好了，那么我们现在的问题来了，自己手动维护说的底维护的是什么，我写了一个spark代码大家看一下
import org.apache.kafka.common.serialization.StringDeserial最后
以上就是傲娇八宝粥为你收集整理的Kafka的偏移量到底是什么，手动维护又是什么的全部内容，希望文章能够帮你解决Kafka的偏移量到底是什么，手动维护又是什么所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
发表评论 取消回复