使用KafkaListener时，如何检查主题消息是否已读完？

使用@KafkaListener时，如何检查主题消息是否已读完？

See 这个答案 https://stackoverflow.com/questions/55430893/how-to-check-if-kafka-is-empty-using-spring-kafka/55432339#55432339有关在没有更多记录可供读取时获取事件通知的信息。

您可以使用Consumer如果要获得当前的position(), and endOffsets();下面显示了如何获取结束偏移量：

@EventListener
void listen(ListenerContainerIdleEvent event) {
    System.out.println(event);
    try {
        System.out.println(event.getConsumer().assignment());
        System.out.println(event.getConsumer().endOffsets(event.getConsumer().assignment(), Duration.ofSeconds(5)));
    }
    catch (Exception e) {
        e.printStackTrace();
    }
}