调测Spring-Kafka模块访问Kafka样例程序

操作步骤

1. 开启Kafka Plain认证。

   登录FusionInsight Manager页面，选择“集群 > 服务 > Kafka > 配置 > 全部配置”，搜索参数“sasl.enabled.mechanisms”，将参数值改为“GSSAPI,PLAIN”，单击“保存”。在Kafka服务“概览”页面，选择“更多 > 重启服务”使配置生效。

2. 获取“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”。

3. 在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”上传到当前路径下。

4. 执行命令启动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。

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

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

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

   

6. 消费数据。

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

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

   图2 消费数据