更新时间:2024-01-18 GMT+08:00

收集连接信息

Kafka实例信息准备

  • 实例连接地址与端口

    实例创建后,从Kafka实例控制台的基本信息页面中获取。Kafka实例为集群部署时,至少有3个连接地址,在客户端配置时,建议将连接地址都配上。

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

    图1 查看Kafka实例Broker连接地址与端口
  • Topic名称

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

    图2 查看Topic名称
  • SASL信息

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

    • SASL用户名在Kafka实例控制台的“用户管理”页面中查看,如果忘记密码,可通过重置SASL_SSL密码重新获得。
      图3 查看SASL用户名
    • SSL证书在Kafka实例控制台的基本信息页面中下载。

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

    • SASL认证机制在Kafka实例控制台的基本信息页面中获取。如果SCRAM-SHA-512和PLAIN都开启了,根据实际情况选择其中任意一种配置连接。如果页面未显示“开启的SASL认证机制”,默认使用PLAIN机制。
      图4 开启的SASL认证机制
    • Kafka安全机制在Kafka实例控制台的基本信息页面中获取。如果页面未显示“启用的安全协议”,默认使用SASL_SSL协议。