Spring Kafka模板实现示例，用于查找偏移、确认

Question

我不熟悉SpringKafka模板。我在里面试了一些基本的东西，效果很好。但我试图实现Spring文档中提到的一些概念，比如：

1. 偏移搜索

我试图在网上为它找到一些例子，但没有成功。我只找到了它的源代码。

我们在这篇文章中提到了同样的问题Spring kafka消费者，在运行时寻求偏移。

但是没有可用的例子来实现相同的。

有人能举例说明如何实施它们吗？

提前感谢。

Answer 1

为此，您应该使用ConsumerSekAware来处理以下问题：

static class Listener implements ConsumerSeekAware {

     private final ThreadLocal<ConsumerSeekCallback> seekCallBack = new ThreadLocal<>();

     public void registerSeekCallback(ConsumerSeekCallback callback) {
        this.seekCallBack.set(callback);
    }

@KafkaListener(...)
        public void listen(@Payload String foo,
                Acknowledgment ack) {

                this.seekCallBack.get().seek(topic, partition, 0);
            }
        }

}