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