本小节介绍如何使用 Spring Cloud 框架接入 Kafka 并收发消息。

前提条件

下载 Demo

下载 Demo。将 Demo 上传至准备好的 Linux 服务器上， Demo 包含如下文件：

文件名 文件路径 说明

KafkaDemoApplication.java

/src/main/java/com/qingcloud/

Kafka demo 应用程序。

MyInput.java

/src/main/java/com/qingcloud/

消费消息的 API。

MyOutput.java

/src/main/java/com/qingcloud/

生产消息的 API。

application.properties

/src/main/resources/

Kafka demo 配置文件，用于配置 Kafka 的连接信息。

package.xml

/src/main/resources/

Maven 基本信息。

pom.xml

/

Maven 配置文件。

run_demo.sh

/

Kafka demo 应用程序执行脚本，通过该脚本可以发送和接收消息。

运行 Demo

  1. 进入 Demo 包所在路径。

  2. 执行以下命令，进入配置文件所在路径。

    cd src/main/resources/

  3. 执行以下命令，编辑 application.properties 配置文件，并配置相关信息。

     vi application.properties
    参数 参数说明

    kafka.bootstrap-servers

    Kafka 连接地址。若 Kafka 节点地址为：192.168.0.1, 192.168.0.2, 192.168.0.3, 则接入点为：192.168.0.1:9092,192.168.0.2:9092,192.168.0.3:9092。

    kafka.consumer.group

    订阅消息的 Group。您可以自定义，系统将会自动创建一个 Group。

    kafka.output.topic.name

    消息的 Topic。程序向此 Topic 周期性地发送同一内容的消息。

    kafka.input.topic.name

    消息的 Topic。发送消息到此 Topic，Demo 程序会消费此 Topic 的消息，并将消息打印在日志中。

    		 
     ###请将参数修改为实际使用的 Kafka 信息
 kafka.bootstrap-servers=XXX
 kafka.consumer.group=XXX
 kafka.output.topic.name=XXX
 kafka.input.topic.name=XXX

  4. 进入 demo 包所在路径，执行以下命令，运行 run_demo.sh 脚本。

    sh run_demo.sh

    • 程序打印输出 "Send: hello world !!"，说明 kafka.output.topic.name 配置的 Topic 收到程序所发送的消息。

      kafka_output_topic_name

    • 向 kafka.input.topic.name 配置的 Topic 发送消息，若 Demo 程序日志中打印输出类似如下消息，说明 kafka.input.topic.name 配置的 Topic 能正常消费消息。

      kafka_input_topic_name