步骤二:创建 Topic
Kafka 通过 Topic 进行生产消息和消费消息,生产者往 Topic 中写消息,消费者从 Topic 中读消息。
本小节主要介绍如何通过 Kafka Manager 或 Kafbat UI 创建 Topic。您也可以通过 Kafka 命令行工具创建 Topic,具体操作请参见 Kafka 客户端命令行方式创建 Topic。
前提条件
Kafka Manager
访问 Kafka Manager
-
在本地浏览器里输入 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-manager.basicAuthentication.enabled 进行设置,默认为
false
,不需要登录验证。
创建 Topic
-
在 Kafka Manager 点击目标 Cluster 名称,进入 Cluster 详情页面。
-
选择 Topic > Create,进入 Create Topic 页面。
-
配置相关参数,若不单独给 Topic 配置参数,会使用集群级别默认参数。
-
配置完成后,点击 Create,完成 Topic 创建操作。
Kafbat UI
访问 Kafbat UI
-
在本地浏览器里输入 Kafbat UI 地址
http://client_ip:port
。-
client_ip 为 客户端节点的 IP 地址。
-
内网连接:IP 地址为客户端节点内网 IP。
-
公网连接:IP 地址为客户端节点绑定的公网 IP。
-
-
port 为 Kafbat UI 的访问端口,可通过集群配置参数 kafka-manager.port 进行设置,默认为
9000
。
-
-
如果集群配置参数
kafka-manager.basicAuthentication.enabled
设置为true
,则表示需要登录,请使用配置的帐号登录。该参数默认为false
,即不需要登录。集群参数配置可参考修改配置参数。
创建 Topic
-
在 Kafbat UI 页面,点击左侧 Topics,进入 Topic 列表页面。
-
在 Topic 列表页面,点击右上角的 + Add Topic,弹出 Topic 创建对话框。
-
用户根据页面信息,填写相关参数后,点击Create Topic,完成 Topic 创建操作。
Topic Name
为必填项,其余参数若不填写,系统会使用集群级别默认参数。