1.1、新建springboot脚手架工程。 pom文件如下，其中导入了kafka所需的依赖关系。 注意，此处的kafka版本号必须与以前安装的kafka版本匹配，否则有问题
？ XML版本=' 1.0 '编码=' utf-8 '？ project xmlns=' http://maven.Apache.org/POM/4.0.0 ' xmlns : xsi=' http://www.w3.org/2001/XML方案ins ttins maven-4.0.0.xsd ' model版本4.0.0/modelversiongroupidcom.ze artifactidversion0.0.1- snapshot/versionparsion namedescriptionkafka集成/escriptionparentgroupidorg.spring framework.boot/groupidartifactidspring-boot-starter-parenend artifactidversion2--- lookupparentfromrepository---parentpropertiesproject.build.sourcencodingutf-8/project.build.sourceencodingproject.reporting.outputencodingutf-8/project.reporting.outputencodingjava.versiing propertiesdependenciesdependencygroupidorg.spring framework.boot/groupidartifactidspring-boot-starter-web/artifaccer ependencydependencygroupidorg.spring framework.Kafka/groupididard artifactidversion2.1. 10.rel lesion ependencydependencygroupidorg.spring框架. boot/groupidartifactidspring-bot artifactidscopetest ependenciesbuildpluginsplugingroupidorg.spring framework.boot/groupidartifactidspring-boot-maven -
Kafka.consumer.zookeeper.connect=127.0.0.133602181 Kafka.consumer.servers=127.0.0.133609092 Kafka.133 val=100 Kafka.consumer.auto.offset.reset=latest spring.kaf ker
package com.ze shan.Kafka consumer； importorg.Apache.Kafka.clients.consumer.consumer record； import org.slf4j.Logger； import org.slf4j.LoggerFactory； importorg.spring framework.Kafka.annotation.Kafka listener； importorg.spring framework.stereotype.com ponent； @ componentpublicclassconsumer { privatestaticloggerlogger=logger factory.getlogger (consumer.class )； @ Kafka监听器(topics=' demo ' )公共语音监听器(consumerrecord )？ record () { logger.info ) )主题：{} )内容： {}、record.topic )、record.value )； }4.启动项目并访问http://127.0.0.1:6060/Kafka-producer/send？ 消息=你好，
可以在控制台上看到消息的打印，这就完成了springboot集成kafka消费者。
项目的源地址https://gitee.com/Yan faze/Kafka.git
以下博客介绍了kafka群集和kafka的配置信息。