使用 spring 多次迭代 kafka 主题

Question

我想多次迭代 Kafka DL 主题。我可以找到一个实现 here。另一个可能正在使用 spring 云。不确定我是否可以用这些一遍又一遍地迭代。

哪个更好？或者除了上述两种之外还有更好的方法吗？

有寻找最旧可用偏移量选项的消费者？如果这是更好的方法，我们如何才能找到最早的方法？我知道 consumer-auto-offset-reset 属性 只有在创建新的消费者组时才具有相关性，这在我的情况下不实用。

Answer 1

请参阅 中的 EDIT2，了解如何在每次应用程序启动时查找到开头。