美文网首页
kafka消息阻塞排查

kafka消息阻塞排查

作者: 催化剂 | 来源:发表于2023-04-23 11:24 被阅读0次

kafka大讲座:https://www.cnblogs.com/zackstang/category/1520711.html

1、#找到kafka目录,并进入

find / -name kafka-consumer-groups.sh

cd /opt/kafka_2.12-1.0.0/bin

2、# 查看iot的消费组

./kafka-consumer-groups.sh --bootstrap-server kafka-server:9092 --list --new-consumer | grep iot

./kafka-consumer-groups.sh --bootstrap-server kafka-server:9092 --describe --new-consumer --group ${topic} 

内容是上面查询的结果 例如 iot-mongo-sink-server-group_iot-monitor-sink-data

完整命令举例:./kafka-consumer-groups.sh --bootstrap-server kafka-server:9092 --describe --new-consumer --group iot-mongo-sink-server-group_iot-monitor-sink-data

相关文章

  • 项目笔记5-KafKa

    目前最好的异步消息队列处理器 阻塞队列 写一个生产者消费者模式,使用阻塞队列 Kafka入门 消息持久化:消息永久...

  • 发现kafka丢消息后的排查

    背景: 最近在用kafka做消息中间件,producer从hive中读取消息发送到kafka,后端storm...

  • kafka消息有效期设置

    问题描述: 昨天晚上,先收到kafka主机磁盘告警,然后收到kafka端口告警,三台kafka同时挂掉。 排查: ...

  • 前腾讯T3架构师分享:记一次 Kafka 集群线上扩容

    前段时间收到某个 Kafka 集群的生产客户端反馈发送消息耗时很高,于是花了一段时间去排查这个问题,最后该集群进行...

  • Hiveserver2阻塞原因排查

    背景 在修改表location与默认的hdfs机器不一致导致hiveserver2阻塞 排查 使用jstack排查...

  • Kafka常用命令

    启动Kafka并生产消费消息 启动ZooKeeper 启动Kafka 查看启动后kafka的版本 生产者发送消息 ...

  • Kafka/RocketMQ顺序消息对比

    一、Kafka顺序消息 Producer端:Kafka的顺序消息是通过partition key,将某类消息(例如...

  • Kafka实践

    kafka基本概念: Kafka是一个分布式消息队列。Kafka对消息保存时根据Topic进行归类,发送消息者称为...

  • Kafka的基本原理及集群架构

    Kafka简介 Kafka是一个分布式消息队列。Kafka对消息保存时根据Topic进行归类,发送消息者称为Pro...

  • 消息屏障

    消息屏障 只会阻塞普通消息,不会阻塞异步消息,绘制消息是异步消息,下面的插入消息屏障,就是为了优先处理绘制消息。

网友评论

      本文标题:kafka消息阻塞排查

      本文链接:https://www.haomeiwen.com/subject/vuaejdtx.html