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 为必填项,其余参数若不填写,系统会使用集群级别默认参数。