spring boot集成Kafka

    分为两种类型的集成

  以消费者的形式集成Kafka

  以生产者的形式集成Kafka

  
        8
        8
        
        2.1.3.RELEASE
    
    
        
            
            
                org.springframework.boot
                spring-boot-dependencies
                ${spring.boot.version}
                pom
                import
            
        
    

    
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            org.springframework.kafka
            spring-kafka
        
    

spring:
  kafka:
    consumer:
      group-id: 消费组ID
      auto-offset-reset: latest
      enable-auto-commit: true
      bootstrap-servers: kafka地址
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.ByteArrayDeserializer

@Component
public class Consumer{



    @KafkaListener(topics = "topic值")
    public void listen(ConsumerRecord record) {

    }

}