kafka查看消费记录
终极管理员 知识笔记 259阅读
kafka 里面的 topic消费情况如何查看？
答：kafka 里面的 topic消费情况查看 1.进入zookeeper的客户端界面：./zkCli.sh (在zookeeper目录的bin下） 查看 目录：ls /consumers 2. kafka 的bin目录下执行： ./ kafka -consumer-groups.sh --describe --group xiothub_jtm2m_rawdata_210_xgit_m2m_jt_...
如何计算kafka中某个消费者的滞后量？
答：由于B、C拉取A消息之间延时问题，所以HW必然不会一直与Leader的LEO相等，即LEO>=HW。 要计算Kafka中某个消费者的滞后量很简单，首先看看其消费了几个Topic，然后针对每个Topic来计算其中每个Partition的Lag，每个Partition的Lag计算就显得非常的简单了，参考下图：
如何检测kafka的消费数据有没有积压？
答：请以实际情况为准！ 如果需要使用shell脚本，来检测kafka的消费数据，有没有积压。 可以先使用--list命令，然后对结果使用for循环遍历，将组名赋予到--group参数上即可！ 本文参与 腾讯云自媒体分享计划 ，欢迎正在阅读的你也加入，一起分享。
什么是kafka？
答：对于Kafka而言，消息被发送至Topic中，而Topic又分成了多个分区 (Partition)，每一个Partition都有一个预写式的日志文件，虽然Partition可以继续细分为若干个段文件 (Segment)，但是对于上层应用来说可以将Partition看成最小的存储单元 (一个由多个Segment文件拼接的“巨型文件”)。 每个Partition都由一系列有序的、不可变的消息组成，这些消息被连续的追加到Partition中。