如何从 Java class 检查应用程序是否已使用消息？
How can I check from a Java class that an application has consumed a message?
有一个应用程序在使用了 kafka 事件后对数据库进行了一些更改，但我不是检查对数据库的影响ì，而是想知道是否有一种方法可以在消息被使用时以编程方式检查（不使用命令行）。
如果您需要 API 支持，您可以使用下面提到的链接：
目前我找到了这个解决方案：
我以编程方式创建了一个 KafkaConsumer，它具有与我要测试的消费者相同的 group.id，然后我使用 "committed" 方法获取分区主题组的最新提交偏移量兴趣
它不是最佳的，后来我尝试获得更低的级别，但它完成了工作。
有一个应用程序在使用了 kafka 事件后对数据库进行了一些更改，但我不是检查对数据库的影响ì，而是想知道是否有一种方法可以在消息被使用时以编程方式检查（不使用命令行）。
如果您需要 API 支持，您可以使用下面提到的链接：
目前我找到了这个解决方案：
我以编程方式创建了一个 KafkaConsumer，它具有与我要测试的消费者相同的 group.id，然后我使用 "committed" 方法获取分区主题组的最新提交偏移量兴趣
它不是最佳的，后来我尝试获得更低的级别，但它完成了工作。