租户端 互联网中间件 消息队列（CKafka） 操作指南

Topic管理

最近更新时间: 2024-06-12 15:06:00

操作场景

Topic（主题）是某一种分类的名字，消息在 Topic 中可以被存储和发布。CKafka 对外使用 Topic 的概念，生产者往 Topic 中写消息，消费者从 Topic 中读消息。为了做到水平扩展，一个 Topic 实际是由多个 Partition（分区）]组成，遇到瓶颈时，可以通过增加 Partition 的数量进行横向扩容。 该任务指导您通过 CKafka 控制台，在已有实例下 Topic 进行管理。

操作步骤

创建 Topic

  1. 登录 CKafka 控制台。

  2. 在实例列表页，单击目标实例的“ID/名称”，进入实例详情页。

  3. 在实例详情页，单击页面顶部的 Topic 管理，单击新建。

  4. 在编辑 Topic 窗口中，选择分区数和副本数等信息。

    • 名称：Topic 名称，输入后无法更改，名称只能包含字母、数字、下划线、“-”和“.”。

    • 分区数：一个物理上分区的概念，一个 Topic 可以包含一个或者多个 partition，CKafka 以 partition 作为分配单位。

    • 副本数：partition 的副本个数，用于保障 partition 的高可用，为保障数据可靠性，当前不支持创建单副本 Topic，默认开启2副本。副本数也算分区个数，例如客户创建了1个 Topic、6个分区、2个副本，那么分区额度一共用了1 * 6 * 2 = 12个。

    • 白名单：开启白名单后，只有白名单中的 ip 才可访问该 Topic。

  5. 单击【提交】完成 Topic 创建。

删除 Topic

注意：

  • 删除 Topic 的同时，存储在此 Topic 中的消息也将被删除，请谨慎操作。
  • Topic 删除是异步操作，配置删除成功后，ZooKeeper 配置将会在1分钟后生效。若此期间创建同名 Topic，系统会提示错误码 [4000]10011，届时请您稍后重试。

  1. 在实例列表页，单击目标实例的“ID/名称”，进入实例详情页。

  2. 在实例详情页，单击 topic管理标签页，在操作栏单击删除。

  3. 在弹出窗口单击确认，Topic 将被删除。

配置 Topic 高级参数

  1. 在实例列表页，单击目标实例的“ID/名称”，进入实例详情页。

  2. 在实例详情页，单击 topic管理标签页。

  3. 单击操作列的编辑 *> *展示高级配置，设置如下参数：

参数说明如下：

参数名 默认值 参数范围 说明
cleanup.policy delete delete/compact 支持日志按保存时间删除，或者日志按 key 压缩（Kafka Connect 时需要使用 compact 模式）。
min.insync.replicas 1 - 当 producer 设置 request.required.acks 为1时，min.insync.replicas 指定 replicas 的最小数目。
unclean.leader.election.enable true true/false 指定是否能够设置不在 ISR 中 replicas 作为 leader。
segment.ms - 1day - 90days Segment 分片滚动的时长，单位为 ms，最小值为86400000ms。
retention.ms 默认为实例的消息保留时间 60000ms - 90days Topic 维度的消息保留时间。
max.message.bytes - 0B - 8MB Topic 维度的最大消息大小。不填写则默认实例维度消息大小为1MB。