spring-kafka - 使用spring多次迭代kafka主题

Question

我想多次遍历 Kafka DL 主题。我可以在这里找到一个实现。另一种可能是使用弹簧云。不确定我是否可以用这些反复迭代。

哪一个可能更好？或者除了以上两种方法还有什么更好的方法吗？

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

标签： spring-kafkaspring-cloud-stream

Answer 1

请参阅此答案中的EDIT2，了解每次应用程序启动时如何寻找开头。