在springboot中对kafka进行读写的示例代码-创新互联

springboot对kafka的client很好的实现了集成，使用非常方便，本文也实现了一个在springboot中实现操作kafka的demo。

1.POM配置

只需要在dependencies中增加 spring-kafka的配置即可。完整效果如下：

    org.springframework.boot
    spring-boot-starter-parent
    1.5.4.RELEASE
  

  
    1.8
     1.2.2.RELEASE
    UTF-8
  

  
    
      org.springframework.boot
      spring-boot-starter-web
    
    
      org.springframework.boot
      spring-boot-starter
    
    
      org.springframework.boot
      spring-boot-starter-test
      test
    
    
      org.springframework.boot
      spring-boot-starter-aop
    
   
      
      org.springframework.kafka
      spring-kafka
      ${spring-kafka.version}
      
      
      org.springframework.kafka
      spring-kafka-test
      ${spring-kafka.version}
      test