
# SpringBoot使用Spring-Kafka模块访问Kafka样例运行指导
本章节适用于MRS 3.6.0及之后版本。
"module-spring-kafka-examples"样例代码，JDK版本支持JDK 17、JDK 21。
#### 操作步骤
1. 获取"module-spring-kafka-examples-3.6.1-h0.cbu.mrs.351.r1.jar"。 
   在样例代码的"springboot/kafka-examples/module-spring-kafka-examples"目录下找到pom文件，在此文件同级目录使用maven install工具编译SpringBoot样例（编译命令**mvn clean install**），此时会生成一个target文件夹，在target文件夹中得到"module-spring-kafka-examples-3.6.1-h0.cbu.mrs.351.r1.jar"。
   
   
2. 在Windows或Linux上创建一个目录作为运行目录。 
   - Windows环境：创建路径"D:\\Spring", 将"module-spring-kafka-examples-3.6.1-h0.cbu.mrs.351.r1.jar"和"application.properties"上传到当前路径下。
   
   - Linux环境：创建路径"/opt/spring"，将"module-spring-kafka-examples-3.6.1-h0.cbu.mrs.351.r1.jar"和"application.properties"上传到当前路径下。
   
   
   
   
3. 执行命令启动SpringBoot。 
   - Windows环境：打开Windows cmd工具，在目录"D:\\Spring"执行： **java -jar module-spring-kafka-examples-3.6.1-h0.cbu.mrs.351.r1.jar**
     
   
   - Linux环境：在目录"/opt/spring"下执行： **java -jar module-spring-kafka-examples-3.6.1-h0.cbu.mrs.351.r1.jar**
     ![](https://support.huaweicloud.com/devg-lts-mrs/public_sys-resources/note_3.0-zh-cn.png)
     其中JDK版本支持JDK17和JDK 21。
     在Linux环境下，MRS集群中JDK 17版本的Java运行环境（JRE）提供的命令行工具的路径为：${BIGDATA_HOME}/common/runtime/jdk-17.0.13/bin。
     
   
   
   
   
4. 生产数据。 
   - Windows环境：通过执行**curl** 命令，生产数据到Broker。结果如下：
     图1生产数据   
     ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000002247609461.png "点击放大") 
   
   - Linux环境：通过执行**curl** 命令访问SpringBoot。
     **curl http://** *SpringBoot启动时绑定的IP地址* **:** *SpringBoot启动时绑定的端口* **/produce**
     
   
   
   可以在Windows的cmd窗口或者Linux的shell窗口中查看生产数据结果如下：
   ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000002247689345.png "点击放大")
   
   
5. 消费数据。 
   开发者可以自定义一个方法作为Kafka消息的监听器，当指定主题有消息时，该方法会自动被调用，从Broker消费数据。
   可以在Windows的cmd窗口或者Linux的shell窗口中查看消费数据结果如下：
   图2消费数据   
   ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000002212609562.png "点击放大")
   
   
 
