SpringBoot使用Spring-Kafka模块访问Kafka样例运行指导

操作步骤

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

     

     其中 JDK版本仅支持JDK17。

     在Linux环境下，MRS集群中JDK 17版本的Java运行环境（JRE）提供的命令行工具的路径为：${BIGDATA_HOME}/common/runtime/jdk-17.0.13/bin。

4. 生产数据。
   • Windows环境：通过执行curl命令，生产数据到Broker。结果如下：
     图1 生产数据
     
   • Linux环境：通过执行curl命令访问SpringBoot。

     curl http://SpringBoot启动时绑定的IP地址:SpringBoot启动时绑定的端口/produce

   可以在Windows的cmd窗口或者Linux的shell窗口中查看生产数据结果如下：

   

5. 消费数据。

   开发者可以自定义一个方法作为Kafka消息的监听器，当指定主题有消息时，该方法会自动被调用，从Broker消费数据。

   可以在Windows的cmd窗口或者Linux的shell窗口中查看消费数据结果如下：

   图2 消费数据