springboot 集成kafka系列三、springboot集成kafka消费者

全栈程序员-站长 • 2026年3月26日下午7:20 • 未分类 • 阅读 2

1.1、新建springboot脚手架工程，pom文件如下，其中引入了kafka需要的依赖，注意这里的kafka版本号需要和之前安装的kafka版本一致，要不然会有问题

 
   
   
   
     4.0.0 
    
   
     com.zeshan 
    
   
     kafka-consumer 
    
   
     0.0.1-SNAPSHOT 
    
   
     jar 
    
   
     kafka-consumer 
    
   
     kafka集成 
    
    
    
      org.springframework.boot 
     
    
      spring-boot-starter-parent 
     
    
      2.0.2.RELEASE 
     
     
     
    
    
    
      UTF-8 
     
    
      UTF-8 
     
    
      1.8 
     
    
    
     
     
       org.springframework.boot 
      
     
       spring-boot-starter-web 
      
     
     
     
       org.springframework.kafka 
      
     
       spring-kafka 
      
     
       2.1.10.RELEASE 
      
     
     
     
       org.springframework.boot 
      
     
       spring-boot-starter-test 
      
     
       test 
      
     
    
    
     
      
      
        org.springframework.boot 
       
      
        spring-boot-maven-plugin

2、在application.properties中配置consumer基本信息

kafka.consumer.zookeeper.connect=127.0.0.1:2181 kafka.consumer.servers=127.0.0.1:9092 kafka.consumer.enable.auto.commit=true kafka.consumer.session.timeout=6000 kafka.consumer.auto.commit.interval=100 kafka.consumer.auto.offset.reset=latest spring.kafka.consumer.group-id=demo kafka.consumer.concurrency=10

3.编写Consumer

package com.zeshan.kafkaconsumer; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.kafka.annotation.KafkaListener; import org.springframework.stereotype.Component; @Component public class Consumer { private static Logger logger = LoggerFactory.getLogger(Consumer.class); @KafkaListener(topics = "demo") public void listen(ConsumerRecord 
   record){ logger.info("主题:{} 内容：{}",record.topic(),record.value()); } }

4.启动项目，访问http://127.0.0.1:6060/kafka-producer/send?message=你好，

springboot 集成kafka系列三、springboot集成kafka消费者