如何知道一个主题中的所有文档都已被Kafka使用者使用?

yjghlzjz  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(195)

我试图写一个Kafka消费者,在那里我可以流式处理一个主题中的所有文档。我想关闭Kafka消费者一旦所有的文件已经消费,我没有任何其他文件消费。
问题是,既然消费者应该持续阅读并且永不停止,那么有没有一种方法可以让我知道Kafka主题中的所有记录都已被消费并提交,这样我就可以关闭我的消费者?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题