回答:由于B和C拉A消息的延迟,HW必然不会一直等于领导的LEO,即LEO=HW。要计算卡夫卡笔下一个消费者的滞后是很简单的。先看它消耗了多少题目,再计算每个分区对每个题目的滞后。每个分区的滞后计算非常简单。请参考下图:
A:请参考实际情况!如果需要使用shell脚本,检查卡夫卡的消费数据是否积压。可以先使用- list命令,然后使用for循环遍历结果,并将组名赋予- group参数!本文参与腾讯云的自媒体分享计划,欢迎你的加入,与我们分享。
回答:对于Kafka,消息发送到Topic,Topic分为几个分区,每个分区都有预先写好的日志文件。虽然分区可以细分为几个段文件,但分区可以被视为上层应用的最小存储单元(由多个段文件拼接而成的“巨型文件”)每个分区都由一系列有序且不可变的消息组成,这些消息不断追加到分区中。