结论

提交的是 当前消息的 offset+1

源码分析

执行下面代码时：

@KafkaListener(clientIdPrefix = "mycon",topics = {"userlog26"},idIsGroup = false)
public void onMessage(@Payload String message,
                      @Header(KafkaHeaders.RECEIVED_PARTITION_ID) int partition,
                      @Header(KafkaHeaders.RECEIVED_TOPIC) String topic,
                      @Header(KafkaHeaders.OFFSET) String offset,
                      Consumer consumer) {consumer
    // 消费的哪个topic、partition的消息,打印出消息内容
    System.out.println(String.format("消费：topic:%s-partition:%s-offset:%s-value:%s", topic,partition,offset,message));
    //手动异步比较
    consumer.commitAsync();

}

打印的消息中的偏移量是 1

跟踪如下图

提交的 offset 是 2，即：当前消息的 offset+1

图解

原文出处：/show_1IX2L6BMYoNY.html