Kafka 通过 Topic 进行生产消息和消费消息，生产者往 Topic 中写消息，消费者从 Topic 中读消息。

本小节主要介绍如何通过 Kafka Manager 或 Kafbat UI 创建 Topic。您也可以通过 Kafka 命令行工具创建 Topic，具体操作请参见 Kafka 客户端命令行方式创建 Topic。

前提条件

  • 已创建 Kafka 集群，且集群状态为活跃。

  • Kafka 集群已安装客户端节点。

  • 为了方便通过本地浏览器访问，可以为客户端节点绑定公网 IP；如果客户端节点不绑定公网 IP，需要配置 VPN，确保本地可以访问集群网络。

Kafka Manager

访问 Kafka Manager

  1. 在本地浏览器里输入 Kafka Manager 地址 http://client_ip:port。

    • client_ip 为 客户端节点的 IP 地址。Kafka 0.10.2.1 - v1.1.6 版本没有客户端节点，可使用集群内任意节点的 IP。

      • 内网连接：IP 地址为客户端节点内网 IP。

      • 公网连接：IP 地址为客户端节点绑定的公网 IP。

    • port 为 Kafka Manager 的访问端口。通过集群配置参数 kafka-manager.port 进行设置，默认为 9000。

    Kafka clusters

  2. 如果在集群配置参数中指定需要登录，请使用配置的帐号登录。默认为不需要登录。

    是否需要登录验证，通过集群配置参数 kafka-manager.basicAuthentication.enabled 进行设置，默认为 false，不需要登录验证。

创建 Topic

  1. 在 Kafka Manager 点击目标 Cluster 名称，进入 Cluster 详情页面。

  2. 选择 Topic > Create，进入 Create Topic 页面。

  3. 配置相关参数，若不单独给 Topic 配置参数，会使用集群级别默认参数。

    Create topic

  4. 配置完成后，点击 Create，完成 Topic 创建操作。

Kafbat UI

访问 Kafbat UI

  1. 在本地浏览器里输入 Kafbat UI 地址 http://client_ip:port。

    • client_ip 为 客户端节点的 IP 地址。

      • 内网连接：IP 地址为客户端节点内网 IP。

      • 公网连接：IP 地址为客户端节点绑定的公网 IP。

    • port 为 Kafbat UI 的访问端口，可通过集群配置参数 kafka-manager.port 进行设置，默认为 9000。

  2. 如果集群配置参数 kafka-manager.basicAuthentication.enabled 设置为 true，则表示需要登录，请使用配置的帐号登录。该参数默认为 false，即不需要登录。集群参数配置可参考修改配置参数。

创建 Topic

  1. 在 Kafbat UI 页面，点击左侧 Topics，进入 Topic 列表页面。

  2. 在 Topic 列表页面，点击右上角的 + Add Topic，弹出 Topic 创建对话框。

    kafbat_ui_add_topic

  3. 用户根据页面信息，填写相关参数后，点击Create Topic，完成 Topic 创建操作。

    Topic Name 为必填项，其余参数若不填写，系统会使用集群级别默认参数。