spring - Spring Kafka 重放旧消息

Question

如果出现任何问题，我需要重播旧的 Kafka 偏移量。Spring Kafka 中是否有任何 API 可用于重播主题的旧偏移量？

标签： springapache-kafkakafka-consumer-apispring-kafka

Answer 1

就在这里。看看ConsumerSeekAware。用法在此处描述。即，关于这种方法：

void registerSeekCallback(ConsumerSeekCallback callback);

在文档中写道：

容器启动时调用；在初始化后的某个任意时间进行搜索时，应使用此回调。您应该保存对回调的引用；如果您在多个容器（或 ConcurrentMessageListenerContainer）中使用相同的侦听器，则应将回调存储在 ThreadLocal 或其他由侦听器线程键入的结构中。

回调本身记录在这里。