更新时间:2022-11-14 GMT+08:00

修改Topic分区数

创建Kafka实例Topic成功之后,您可以根据业务需要修改Topic的分区数。分区数只支持增加,不支持减少

修改分区数,不会影响业务。

修改Topic分区数的方法如下:

方法1:在控制台修改

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

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

  3. 在管理控制台左上角单击,选择“应用服务 > 分布式消息服务 Kafka”,进入分布式消息服务Kafka专享版页面。
  4. 单击Kafka实例的名称,进入实例详情页面。
  5. 选择“Topic管理”页签,显示已创建的Topic详情。
  6. 通过以下任意一种方法,修改Topic分区数。

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

  7. 在“编辑Topic”对话框中,输入分区数,单击“确定”。

    • 分区数只支持增加,不支持减少。
    • 出于性能考虑,Kafka控制台限定单个Topic的分区数上限为100。
    • 所有Topic分区数总和不能超过实例允许的分区上限。

方法2:在Kafka Manager上修改

  1. 登录Kafka Manager
  2. 在Kafka Manager中,单击“Topic > List”,进入Topic列表界面。
  3. 单击Topic名称,进入Topic详情界面。
  4. 单击“Add Partitions”,进入增加分区界面。

    图1 Topic详情界面

  5. 输入分区数,单击“Add Partitions”。

    图2 增加分区数量

    显示“Done”,表示分区增加成功。

    图3 分区增加成功
    • 分区数只支持增加,不支持减少。
    • 所有Topic分区数总和不能超过实例允许的分区上限。

方式3:在Kafka客户端上修改

Kafka客户端版本为2.2以上时,支持通过kafka-topics.sh修改Topic分区数。

  • 未开启SASL的Kafka实例,在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下,通过以下命令修改Topic分区数。
    ./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --topic {topic_name} --alter --partitions {partition_num}
  • 已开启SASL的Kafka实例,通过以下步骤修改Topic分区数。
    1. (可选)如果已经设置了SSL证书配置,请跳过此步骤。否则请执行以下操作。

      在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件,参考3增加SSL证书配置。

    2. 在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下,通过以下命令修改Topic分区数。
      ./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --topic {topic_name} --alter --partitions {partition_num} --command-config ./config/ssl-user-config.properties