当前位置：首页 > article >正文

Kafka性质小结

article 2024/11/14 14:49:03

1、关于消息偏移量的确认

消息的确认包括自动确认和手动确认，通常采用手动确认的方式，配置项和代码块分别如下所示。这里需要注意的是，当消息1、2、3顺序到达，2偏移量确认失败，3偏移量确认成功时，2的偏移量将被覆盖，即后续将从3的偏移量开始消费，不会再次消费消息2 ！！！

spring:
  kafka:
    consumer:
      ......
      # 关闭自动提交偏移量
      enable-auto-commit: false
    listener:
      # 拉取数据方式: single、batch
      type: single
      # 偏移量提交方式：手动
      ack-mode: manual_immediate

@Component
public class MessageConsumer {
    @KafkaListener(topics = "topic-smy", groupId = "my_group1")
    public void handleMessage(ConsumerRecord<String, String> record, Acknowledgment ack) {
        // 消息处理
        System.out.println("接收到消息, topic = "+ record.topic()
            		+"，partition:"+record.partition()
            		+"，offset = "+record.offset()
            		+"，key = "+record.key()
            		+"，value = "+record.value());
        if(!"0".equals(record.value())) {
            // 消息偏移量确认
            ack.acknowledge();
        }
    }
}