最近更新时间:2025-09-28 17:16:12
Topic,即消息主题,消息发送与接收的基本单元。创建Kafka实例成功后,需要手动创建Topic,然后才能进行生产消息和消费消息。
EFAK(Eagle For Apache Kafka)是一款开源的Kafka 集群监控管理工具,它能提供Kafka 集群Broker 状态、Topic 信息、IO、内存、消费者线程和偏移量等指标的监控与可视化展示。
通过配置WebUI访问可进入EFAK管理后台,本文介绍如何在EFAK中创建和删除Topic。
在EFAK管理后台左侧菜单选择Topics,下拉选择Create。
填写Topic的属性信息,确认提交即完成Topic创建。
Topic Name(主题名称):必填项。主题是 Kafka 中消息分类的基本单位,生产者向主题发送消息,消费者从主题订阅消息。
Partitions(分区数):必填项。分区是 Kafka 实现水平扩展和高并发的核心机制。一个主题可以被分成多个分区,消息被分布存储在这些分区中。
Replication Factor(副本因子):必填项。副本是 Kafka 实现高可用性的机制。每个分区都可以有多个副本(复制品),分散在不同的 Broker 上。其中一个副本是 Leader,负责读写;其他副本是 Follower,只负责从 Leader 同步数据。
Topic 创建注意:
1. 建议把分区数设为 Broker 数量的整数倍,避免各 Broker 分区数不均造成负载倾斜。
2. 经验上限:单分区持续写 ≤10 MB/s(或 TPS ≤ 10 万)。
3. 分区数只能增加不能减少,所以提前按 业务高峰期消费者数量 规划。
4. 生产环境下分区数推荐 3,3 Broker 场景下刚好每个 Broker 存放一份副本,实现最大容错 。
在EFAK管理后台左侧菜单选择Topics,下拉选择List。
在搜索栏中输入需要删除的Tpoic名称,在右侧操作栏中点击删除图标。
弹出的“Delete Topic”弹窗,在admin token中填 keadmin,点击Delete完成删除操作。
纯净模式
