Kafka对接SpringBoot样例运行指导

操作步骤

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

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

2. 在Windows或Linux上创建一个目录作为运行目录。
   • Windows环境：创建路径“D:\Spring”, 将“huawei-spring-boot-kafka-examples-*.jar”和“application.properties”上传到当前路径下。
   • Linux环境：创建路径“/opt/spring”，将“huawei-spring-boot-kafka-examples-*.jar”和“application.properties”上传到当前路径下。

3. 执行命令启动SpringBoot。
   • Windows环境：打开Windows cmd工具，在目录“D:\Spring”执行：

     java -jar huawei-spring-boot-kafka-examples-*.jar

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

     java -jar huawei-spring-boot-kafka-examples-*.jar

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

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

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

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