使用PLAINTEXT协议访问集群
所有文档
menu

消息服务 for Kafka

使用PLAINTEXT协议访问集群

产品详情立即开通

本文介绍创建完集群后,如何使用Kafka脚本通过PLAINTEXT协议访问Kafka集群,PLAINTEXT协议需要在VPC网络下进行使用。如果想使用Java、Go、PHP等语言访问Kakfa集群,请参考开发指南

前提条件

  • 步骤一:创建Kafka集群
  • 步骤二:创建主题
  • 安装JDK1.8及以上版本:JDK下载地址

具体操作步骤

  1. 下载Kafka 2.7.2安装包,上传到Kafka集群所在的同一VPC网络下并进行解压:kafka_2.13-2.7.2.tgz,其中解压后的bin目录为Kafka提供的可执行脚本。
  2. 集群详情中,点击接入点查看PLAINTEXT协议所使用的访问地址和端口。

查看接入点.png

  1. 进入Kafka安装包解压后的bin目录下,使用Kafka脚本访问集群。
  • 查看Topic列表:
kafka-topics.sh --bootstrap-server <PLAINTEXT接入点地址> --list
  • 生产者发送消息,输入命令后会出现">"的标识,此时输入内容并且按下回车即可发送消息:
kafka-console-producer.sh --bootstrap-server <PLAINTEXT接入点地址> --topic <Topic名称>
  • 消费者消费消息:
kafka-console-consumer.sh --bootstrap-server <PLAINTEXT接入点地址> --topic <Topic名称> --group <消费组ID> --from-beginning
  1. 如果通过上述命令能够正常发送和消费消息,则说明当前VPC网络环境下能够通过PLAINTEXT协议正常访问Kafka集群,可以参考开发指南中各种语言访问Kafka集群来实现更复杂的逻辑。
上一篇
步骤三:配置权限认证
下一篇
使用SASL_PLAINTEXT协议访问集群