更新时间:2024-10-15 GMT+08:00
分享

修改Kafka Topic配置

本章节指导您在控制台修改如表1所示Kafka Topic的配置。

修改同步复制、同步落盘、消息时间戳类型、批处理消息最大值和描述,不会重启实例。

表1 Kafka Topic的配置参数

参数名称

说明

分区数

Topic的分区数,修改方法请参见修改Kafka Topic分区数

老化时间

消息的最长保留时间,修改方法请参见修改Kafka消息老化时间

副本数

Topic每个分区的副本数量,修改方法请参见修改Kafka Topic副本数

同步复制

后端收到生产消息请求并复制给所有副本后,才返回客户端。

同步落盘

  • 开启:生产的每条消息都会立即写入磁盘,可靠性更高。
  • 关闭:生产的消息存在内存中,不会立即写入磁盘。

消息时间戳类型

定义消息中的时间戳类型,取值如下:
  • CreateTime:生产者创建消息的时间。
  • LogAppendTime:broker将消息写入日志的时间。

批处理消息最大值

Kafka允许的最大批处理大小,如果启用消息压缩,则表示压缩后的最大批处理大小。

如果增加“批处理消息最大值”的值,且存在消费者版本早于0.10.2,此时消费者的“fetch size”值也必须增加,以便消费者可以获取增加后的批处理大小。

描述

Topic的描述信息。

修改Topic配置

  1. 登录管理控制台。
  2. 在管理控制台左上角单击,选择区域。

    请选择Kafka实例所在的区域。

  3. 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。
  4. 单击Kafka实例的名称,进入实例详情页面。
  5. 在左侧导航栏选择“Topic管理”,进入Topic列表页面。
  6. 通过以下任意一种方法,修改Topic配置。

    • 勾选Topic名称左侧的方框,可选一个或多个,单击信息栏左上侧的“编辑Topic”。
    • 在待修改配置的Topic所在行,单击“编辑”。

  7. 在“编辑Topic”对话框中,修改Topic的配置,单击“确定”。

    • 当副本数为1时,不能开启同步复制功能。
    • 开启同步复制后,需要在客户端配置acks=all或者-1,否则无效。

相关文档