本文介绍如何在VPC环境下通过默认接入点接入消息队列Kafka版并收发消息。

前提条件

您已安装Go。更多信息,请参见安装Go

说明 该kafka-confluent-go-demo不支持Windows系统。

准备配置

  1. 访问aliware-kafka-demos,单击code图标,然后在下拉框选择Download ZIP,下载Demo包并解压。
  2. 在解压的Demo包中,找到kafka-confluent-go-demo文件夹,将此文件夹上传在Linux系统的/home路径下。
  3. 登录Linux系统,进入/home/kafka-confluent-go-demo路径,修改配置文件conf/kafka.json
    {
      "topic": "XXX",
      "group.id": "XXX",
      "bootstrap.servers" : "XXX:XX,XXX:XX,XXX:XX",
      "security.protocol" : "plaintext",
      "sasl.mechanism" : "XXX",
      "sasl.username" : "XXX",
      "sasl.password" : "XXX"
    }
    参数 描述 是否必须
    topic 实例的Topic名称。您可在消息队列Kafka版控制台Topic管理页面获取。
    group.id 实例的Consumer Group。您可在消息队列Kafka版控制台Consumer Group管理页面获取。
    bootstrap.servers 默认接入点的IP地址以及端口。您可在消息队列Kafka版控制台实例详情页面的基本信息区域获取。
    security.protocol 默认接入点的用户认证协议,默认为plaintext。
    sasl.mechanism 消息收发的机制,不需配置。
    sasl.username 不需配置。
    sasl.password 不需配置。

发送消息

执行以下命令发送消息。
go run -mod=vendor producer/producer.go

订阅消息

执行以下命令消费消息。
go run -mod=vendor consumer/consumer.go