更新时间:2025-02-05 GMT+08:00

收集连接信息

在连接Kafka实例生产消费消息前,请先获取以下Kafka实例信息。

实例连接地址与端口

实例创建后,从Kafka实例控制台的基本信息页面中获取。

如果Kafka实例为集群部署,至少有3个连接地址,在客户端配置时,建议配置所有的连接地址,提高可靠性。

如果开启公网访问,还可以使用基本信息页面下方的公网连接地址访问Kafka实例。

图1 查看Kafka实例Broker连接地址与端口

Topic名称

从Kafka实例控制台的Topic管理页面中获取Topic名称。

未开启“Kafka自动创建Topic”功能时,必须先创建Topic,然后客户端才可以连接Kafka实例生产消费消息。

SASL信息

如果实例创建时开启SASL访问,则需要获得SASL_SSL用户名与密码、SSL证书和SASL认证机制。

  • 连接实例的用户名在Kafka实例控制台的“用户管理”页面中查看,如果忘记密码,可通过《分布式消息服务Kafka 用户指南》的“重置SASL_SSL密码”重新获得。
    图2 查看SASL用户名
  • SASL认证机制在Kafka实例控制台的基本信息页面中获取。
    如果SCRAM-SHA-512和PLAIN都开启了,根据实际情况选择其中任意一种配置连接。很久前创建的Kafka实例在详情页如果未显示“开启的SASL认证机制”,默认使用PLAIN机制。
    图3 开启的SASL认证机制
  • SSL证书在Kafka实例控制台的基本信息页面中下载。

    使用Java语言连接实例时,需要用JKS格式的证书。使用Python语言连接实例时,需要用CRT格式的证书。