如何查看Amazon MSK中未投递的消息?

Question

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

是通过启用AWS提供的监控选项来实现的唯一方法吗?

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

Answer 1

从本地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