我用java设计了rest-post-api，它实际上将消息发布到特定的kafka主题，比如它的“producttopic”。
在后台，一个微服务正在监听这个“producttopic”主题，并开始使用消息并保存到db。现在我想编写一个getrestapi来查看作业的进度（它给出了job的输出），比如成功地消耗了多少消息，还有多少消息仍然挂起。这样最终用户就会知道发生了什么。
有办法做到这一点吗？我在google上搜索了很多，我看到的只是命令行查询来查看消息的消耗情况。汇合端没有任何可用的java实现示例。任何帮助都将不胜感激。