You need to enable JavaScript to run this app.
导航
使用默认接入点连接实例
最近更新时间:2023.03.29 11:30:40首次发布时间:2021.08.30 16:20:22

本文介绍在 VPC 网络环境下通过默认接入点连接 Kafka 实例,进行消息生产和消息消费的操作步骤。

背景信息

消息队列 Kafka版提供 PLAINTEXT 协议的普通访问方式,即默认接入点。在 VPC 网络环境下通过默认接入点连接实例时,无需配置用户名及密码,直接访问即可。

前提条件

  • 已获取默认接入点信息,包括连接地址和端口号。详细信息请参考查看接入点
  • 已创建 Topic。操作步骤请参考创建 Topic
  • 已购买火山引擎 ECS,并成功安装 JDK、配置环境变量,并下载了 Kafka 开源客户端,例如 Kafka 2.2.2 客户端

生产消息

  1. 解压 Kafka 客户端文件。

  2. ./bin 目录下,打开终端。

  3. 执行以下命令启动生产者,开始生产消息。

    bash kafka-console-producer.sh --broker-list ${默认接入点} --topic ${Topic名称} 
    

    参数

    说明

    默认接入点

    控制台实例详情页面获取的默认接入点信息,默认接入点仅支持 VPC 访问。

    Topic名称

    Kafka 实例的 Topic 名称。

  4. 输入需要生产的消息内容,按回车键发送此消息到 Kafka 实例。
    光标下输入的每一行内容都将封装到消息中发送到 Kafka 实例。如需停止生产,可以使用 Ctrl+C 命令退出消息生产。

    [root@kafkaecs bin]# bash kafka-console-producer.sh --broker-list kafka-cnngc7an0qpv****.kafka.ivolces.com:9092 --topic mytopic
    >Hello world!
    >This is a Kafka message!
    >^C[root@kafkaecs bin]# 
    

消费消息

  1. 打开另一个终端,执行如下命令消费消息。
    如需停止消费,可以使用 Ctrl+C 命令退出消息消费。

    bash kafka-console-consumer.sh --bootstrap-server ${默认接入点}  --topic ${Topic名称} --group ${消费组名称} --from-beginning
    

    参数

    说明

    默认接入点

    控制台实例详情页面获取的默认接入点信息。

    Topic名称

    Kafka 实例的 Topic 名称。

    消费组名称

    自定义的消费组名称。
    如果您已在配置文件中指定了消费组名称,请确认命令行中配置了相同的名称,否则可能导致消费失败。

  2. 成功操作后,消费者可以收到生产者发送的消息,内容与生产端的消息相同。

    [root@kafka bin]# bash kafka-console-consumer.sh --bootstrap-server kafka-cnngc7an0qpv****.kafka.ivolces.com:9092 --topic mytopic --group grouptest --from-beginning
    Hello world!
    This is a Kafka message!
    ^CProcessed a total of 2 messages
    [root@kafka bin]#