KAFKA消息队列-springboot整合

  org.springframework.kafka
  spring-kafka
  2.3.3.RELEASE

 配置文件

spring:
  #KAFKA
  kafka:
    #以逗号分隔的主机：端口对列表，用于建立与Kafka群集的初始连接
    bootstrap-servers: 172.25.221.206:9092
    consumer:
      enable-auto-commit: true #指定了消费者是否自动提交偏移量，默认值是true，为了尽量避免重复数据和数据丢失，可以把它设置为false，有自己控制合适提交偏移量，如果设置为true， 可以通过设置 auto.commit.interval.ms属性来控制提交的频率。
      #auto-commit-interval: 100 #consumer自动向zookeeper提交offset的频率，默认：5000
      auto-offset-reset: latest #该属性指定了消费者在读取一个没有偏移量后者偏移量无效（消费者长时间失效当前的偏移量已经过时并且被删除了）的分区的情况下，应该作何处理，默认值是latest，也就是从最新记录读取数据（消费者启动之后生成的记录），另一个值是earliest，意思是在偏移量无效的情况下，消费者从起始位置开始读取数据。