如何在Amazon MSK中查看未交付的消息?

发布于 2025-01-22 12:15:40 字数 235 浏览 4 评论 0原文

我正在浏览AWS的服务MSK,该服务是Kafka的管理服务。我想检查消费者从生产者发送后,消费者没有消耗多少邮件。

通过启用监视选项AWS提供的唯一方法是这样做的?

由于我尝试了一般的Kafka命令和其他与Kafka相关的Stackoverflow答案,因此它们没有为MSK工作。为什么我们不能这样做?当我在Instnace中使用Zookeeper String的Zookeeper字符串点击 - 描述选项时,那里也没有滞后列。

I was going through AWS 's service MSK which is Managed Service for Kafka. I wanted to check how many messages have not been consumed by the consumer after I send them from a producer.

Is the only way to do it via enabling the Monitoring options AWS provides?

Because I tried the general Kafka commands and other Stackoverflow answers related to Kafka, they have not worked for MSK. And why can't we do this? When I hit the --describe option with my zookeeper string in my instnace, there is no LAG column there either.

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

做个ˇ局外人 2025-01-29 12:15:40

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

Execute below command from local Kafka/bin directory

bin/kafka-consumer-groups.sh --bootstrap-server kafka-bootstrap-ip:9092 --describe --group my-group 
  1. Update kafka-bootstrap-ip with actual kafka cluster ip address.

  2. Update my-group with actual group name

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文