如何查看Amazon MSK 中未送达的消息?

How to check the undelivered messages in Amazon MSK?

我正在使用 AWS 的服务 MSK,它是 Kafka 的托管服务。我想检查从生产者发送消息后,有多少消息未被消费者消费。

启用 AWS 提供的监控选项是唯一的方法吗?

因为我尝试了一般的 Kafka 命令和其他与 Kafka 相关的 Whosebug 答案,它们不适用于 MSK。为什么我们不能这样做?当我在我的实例中使用我的 zookeeper 字符串点击 --describe 选项时,那里也没有 LAG 列。

从本地 Kafka/bin 目录执行以下命令

bin/kafka-consumer-groups.sh --bootstrap-server kafka-bootstrap-ip:9092 --describe --group my-group 
  1. 使用实际的 kafka 集群 ip 地址更新 kafka-bootstrap-ip。

  2. 更新 my-group 为实际组名