收集连接信息

实例连接地址与端口

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

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

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

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

Topic名称

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

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

密文接入信息

如果实例开启密文接入，则需要获得连接实例的用户名与密码、SASL认证机制和Kafka安全协议。Kafka安全协议设置为“SASL_SSL”时，还需要获取SSL证书。

• 连接实例的用户名在Kafka实例控制台的“用户管理”页面中查看，如果忘记密码，可通过重置密码重新获得。
  图2 查看SASL用户名
  
• SASL认证机制在Kafka实例控制台的基本信息页面中获取。

  如果SCRAM-SHA-512和PLAIN都开启了，根据实际情况选择其中任意一种配置连接。很久前创建的Kafka实例在详情页如果未显示“开启的SASL认证机制”，默认使用PLAIN机制。

  图3 开启的SASL认证机制
  
• Kafka安全协议在Kafka实例控制台的基本信息页面中获取。很久前创建的Kafka实例在详情页如果未显示“启用的安全协议”，默认使用SASL_SSL协议。
  图4 启用的安全协议
  
• 如果Kafka安全协议设置为“SASL_SSL”，在Kafka实例控制台的基本信息页面中下载证书。

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