Spring云流-kafka-空确认标头

Question

我想使用spring cloud stream手动提交偏移量-仅当消息处理成功时。这是我的代码应用程序。yml公司

      public void process(Message<?> message) {
         System.out.println(message.getPayload());
         Acknowledgment acknowledgment = message.getHeaders().get(KafkaHeaders.ACKNOWLEDGMENT, Acknowledgment.class);
        if (acknowledgment != null) {
           System.out.println("Acknowledgment provided");
           acknowledgment.acknowledge();
        }
    }
---------------------------------------------------------------------------------
spring:
  application:
      name: springCloud
  cloud:
      stream:
          default-binder: kafka
          kafka:
              bindings:
                  myChannel:
                      consumer:
                          autoCommitOffset: false

但我的确认对象为空，因为在标头中，对象“kafka\u确认”本身不存在。

1. 如何获取确认对象

Answer 1

使用yaml文件时，请使用属性“自动提交偏移量”。

Answer 2

您使用的是什么版本？

在3.1中，不建议使用autoComentOffset，而支持设置ackMode（在本例中为手册）；但是，看起来autoComentOffset现在被完全忽略而不是不建议使用。