You need to enable JavaScript to run this app.
文档中心
消息队列 Kafka版

消息队列 Kafka版

请输入
  • 文档首页
    • 消息队列 Kafka版快速入门连接实例使用 PLAINTEXT 接入点连接实例
复制全文
下载 pdf
我的收藏
连接实例
使用 PLAINTEXT 接入点连接实例
复制全文
下载 pdf
我的收藏
使用 PLAINTEXT 接入点连接实例
本文介绍在 VPC 网络环境下通过 PLAINTEXT 接入点连接 Kafka 实例，进行消息生产和消息消费的操作步骤。​
背景信息​
消息队列 Kafka版提供 PLAINTEXT 协议的普通访问方式，即默认接入点。在 VPC 网络环境下通过 PLAINTEXT 接入点连接实例时，无需配置用户名及密码，直接访问即可。​
前提条件​
  • 已获取 PLAINTEXT 接入点信息，包括连接地址和端口号。详细信息请参考查看接入点。​
  • 已购买火山引擎 ECS，并成功安装 JDK、配置环境变量，并下载了 Kafka 开源客户端，例如 Kafka 2.2.2 客户端。​
生产消息​
  1. 解压 Kafka 客户端文件。​
  1. 在 ./bin 目录下，打开终端。​
  1. 执行以下命令启动生产者，开始生产消息。​
  • ​
    bash kafka-console-producer.sh --broker-list ${默认接入点} --topic ${Topic名称} ​
    ​
  • ​
    参数​
    说明​
    默认接入点​
    控制台实例详情页面获取的 PLAINTEXT 接入点信息，PLAINTEXT 接入点仅支持 VPC 访问。​
    Topic名称​
    Kafka 实例的 Topic 名称。​
    ​
  1. 输入需要生产的消息内容，按回车键发送此消息到 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​
    ​
  • ​
    参数​
    说明​
    默认接入点​
    控制台实例详情页面获取的 PLAINTEXT 接入点信息，PLAINTEXT 接入点仅支持 VPC 访问。​
    Topic名称​
    Kafka 实例的 Topic 名称。​
    消费组名称​
    自定义的消费组名称。​
    如果您已在配置文件中指定了消费组名称，请确认命令行中配置了相同的名称，否则可能导致消费失败。​
    ​
  1. 成功操作后，消费者可以收到生产者发送的消息，内容与生产端的消息相同。​
  • ​
    [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]# ​
    ​
​
最近更新时间：2025.06.27 14:15:22
这个页面对您有帮助吗？
有用
有用
无用
无用