如何查看kafka中消息的进度状态？
How to check the progress status of the messages in kafka?
我在 java 中设计了 REST Post API，它实际上将消息发布到特定的 Kafka 主题，比如说它的“ProductTopic”。
在后台，微服务正在侦听此“ProductTopic”主题并开始使用消息并保存到数据库。现在我想写一个 GET REST API 来查看作业的进度（它给出了作业的输出），比如成功使用了多少消息以及如何仍然悬而未决。这样最终用户就会知道发生了什么。
有办法实现吗？我确实在 google 中搜索了很多，我所看到的只是命令行查询以查看消息的消耗情况。汇合端没有任何 java 实施示例。任何帮助将不胜感激。
您应该检查您服务的消费者组的消费者延迟。滞后约为 endOffset-currentOffset。您可以找到示例
我在 java 中设计了 REST Post API，它实际上将消息发布到特定的 Kafka 主题，比如说它的“ProductTopic”。
在后台，微服务正在侦听此“ProductTopic”主题并开始使用消息并保存到数据库。现在我想写一个 GET REST API 来查看作业的进度（它给出了作业的输出），比如成功使用了多少消息以及如何仍然悬而未决。这样最终用户就会知道发生了什么。
有办法实现吗？我确实在 google 中搜索了很多，我所看到的只是命令行查询以查看消息的消耗情况。汇合端没有任何 java 实施示例。任何帮助将不胜感激。
您应该检查您服务的消费者组的消费者延迟。滞后约为 endOffset-currentOffset。您可以找到示例