文档首页/ MapReduce服务 MRS/ 开发指南（LTS版）/ Kafka开发指南（安全模式）/ 调测Kafka应用/ 调测Kafka SpringBoot样例程序
更新时间：2024-06-15 GMT+08:00
查看PDF
分享

调测Kafka SpringBoot样例程序

  1. 开启Kafka Plain认证。

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

  2. 获取“huawei-spring-boot-kafka-examples-*.jar”。

    在样例代码的“springboot/kafka-examples”目录下找到pom文件，在此文件同级目录使用maven install工具编译SpringBoot样例，此时会生成一个target文件夹，在target文件夹中得到“huawei-spring-boot-kafka-examples-*.jar”。

  3. 在Windows或Linux上创建一个目录作为运行目录。

    • 在Windows创建路径“D:\Spring”, 将“huawei-spring-boot-kafka-examples-*.jar”和application.properties上传到当前路径下面。
    • 在Linux上创建路径“/opt/spring”，将“huawei-spring-boot-kafka-examples-*.jar”和application.properties上传到当前路径下面。

  4. 执行命令启动SpringBoot。

    • Windows环境下在目录“D:\Spring”打开Windows cmd工具执行：

      java -jar huawei-spring-boot-kafka-examples-2.8.1-SNAPSHOT.jar

    • Linux环境下在目录“/opt/spring”下执行：

      java -jar huawei-spring-boot-kafka-examples-2.8.1-SNAPSHOT.jar

  5. 生产数据。

    • Window环境下在浏览器中访问链接：http://SpringBoot启动时绑定的IP地址:Springboot启动时绑定的端口/produce，生产数据到Broker。结果如下：
      图1 生产数据
    • Linux环境下通过执行curl命令访问SpringBoot。

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

  6. 消费数据。

    • Window环境下在浏览器中访问链接：http://SpringBoot启动时绑定的IP地址:Springboot启动时绑定的端口/consume，从Broker消费数据。结果如下：
      图2 消费数据
    • Linux环境下通过执行curl命令访问SpringBoot。

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

父主题： 调测Kafka应用

相关文档