在我的kafkajava项目中，我希望在所有感兴趣的消费者收到新消息后立即删除这些消息。经过一番研究，我发现了一些老问题：这里，还有一个和这里。读完这些，我有一些问题。
据我所知，我真的应该依靠时间或空间的保留。然而，答案是旧的，所以也许有什么改变？有没有其他方法可以确保在当前连接的所有用户都阅读完邮件后立即删除邮件？在这种情况下，我需要检查是否所有的消费者都阅读了该消息。我需要一个消费群体吗？
先谢谢你。
在我的kafkajava项目中，我希望在所有感兴趣的消费者收到新消息后立即删除这些消息。经过一番研究，我发现了一些老问题：这里，还有一个和这里。读完这些，我有一些问题。
据我所知，我真的应该依靠时间或空间的保留。然而，答案是旧的，所以也许有什么改变？有没有其他方法可以确保在当前连接的所有用户都阅读完邮件后立即删除邮件？在这种情况下，我需要检查是否所有的消费者都阅读了该消息。我需要一个消费群体吗？
先谢谢你。
1条答案
按热度按时间zqdjd7g91#
你不必担心邮件何时会被删除或压缩以达到你的目标
就您的消费者而言，如果消费者提交了他们所消费的每条消息的偏移量，那么那些经过处理的消息，无论它们在主题中停留多长时间，在您的消费者看来都是死消息。
注：
管理用户可以去重新设置你的消费者，从一开始就读取增益，包括那些你的消费者开始阅读的消息。但这是一个手动管理操作。