springboot整合kafka

1、@EnableKafka

用于使@KafkaListener生效

2、@KafkaListener(id = "consumer8", topics = "test2")

3、引入jar包

        
        
            org.springframework.kafka
            spring-kafka
            2.2.7.RELEASE
        

4、配置项

spring:
  kafka:
    # 指定kafka 代理地址，可以多个
    bootstrap-servers: 172.16.15.30:9092
    consumer:
      auto-offset-reset: earliest
      enable-auto-commit: true
      auto-commit-interval: 100
      properties:
        max:
          poll:
            interval:
              ms: 600000
      max-poll-records: 2

对应类：org.springframework.boot.autoconfigure.kafka.KafkaProperties

是springboot的自动配置类

5、使用ACk机制确认消费（手动提交）

只需简单的三步即可࿱