在使用@KafkaListener时，当我想要读取endOffsets时，是否可以获得对底层KafkaConsumer的引用

在使用@KafkaListener时，当想要读取endOffsets时，可以通过使用KafkaMessageListenerContainer的方法来获得对底层KafkaConsumer的引用。

KafkaMessageListenerContainer是Spring Kafka提供的一个核心组件，用于管理Kafka消息监听器的容器。它负责创建和管理KafkaConsumer实例，并将消息传递给监听器进行处理。

要获得对底层KafkaConsumer的引用，可以通过在@KafkaListener注解的方法参数中添加一个类型为Consumer<?, ?>的参数。例如：

@KafkaListener(topics = "myTopic")
public void listen(Consumer<?, ?> consumer, @Payload String message) {
    // 在方法中可以使用consumer来访问底层KafkaConsumer的方法
    Map<TopicPartition, Long> endOffsets = consumer.endOffsets(Arrays.asList(new TopicPartition("myTopic", 0)));
    // 其他业务逻辑处理
}

在上述示例中，通过将Consumer<?, ?>类型的参数添加到@KafkaListener注解的方法中，可以在方法内部使用consumer对象来调用底层KafkaConsumer的方法。在这里，使用consumer.endOffsets()方法来获取指定TopicPartition的endOffsets。

需要注意的是，为了使用这种方式获得对底层KafkaConsumer的引用，需要在配置文件中设置spring.kafka.listener.type=record，以确保KafkaMessageListenerContainer使用的是RecordMessagingMessageListenerAdapter。

推荐的腾讯云相关产品是腾讯云消息队列 CMQ，它是一种高可靠、高可用的分布式消息队列服务，适用于异步通信、流量削峰、解耦、日志处理、消息通知等场景。您可以通过腾讯云消息队列 CMQ来实现类似Kafka的功能。详情请参考腾讯云消息队列 CMQ产品介绍：https://cloud.tencent.com/product/cmq