Confluent修改kakfa中分区数和副本数

た入场券 2022-12-12 15:24 232阅读 0赞

准备工作：

已经创建了一个分区数为1，副本数为1的Topic,Topic的名为：\_confluent-ksql-ksql\_application\_\_configs。  主题参数如下图所示。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjA3MDQ3Mw_size_16_color_FFFFFF_t_70][]

注：查看Topic的命令： （bin/kafka-topics 为Confluent的绝对路径）

bin/kafka-topics --bootstrap-server node01:9092 --topic _confluent-ksql-ksql_application__configs --describe

## 一、修改分区数（分区数只能修改为比之前大的分区数） ##

修改命令：

bin/kafka-topics --alter --zookeeper 192.168.87.101:2181 --topic _confluent-ksql-ksql_application__configs --partitions 3

结果：

![20201008143516615.png][]

## 二、修改副本数 ##

**步骤：**

1.创建一个json文件，此处我创建了一个名为increase-replication-factor.json的文件。 文件内容：

{"version":1,
    "partitions":[
    {"topic":"_confluent-ksql-ksql_application__configs","partition":0,"replicas":[1,2,3]},
    {"topic":"_confluent-ksql-ksql_application__configs","partition":1,"replicas":[1,2,3]},
    {"topic":"_confluent-ksql-ksql_application__configs","partition":2,"replicas":[1,2,3]}
    ]}

内容解释：

"topic":"\_confluent-ksql-ksql\_application\_\_configs"   :  为我要修改的topic的名字

"partition": \* ：  修改副本的某个分区

"replicas":\[1,2,3\]  ：  1,2,3为自己设置的broker.id

2.输出命令：

bin/kafka-reassign-partitions --zookeeper node01:2181,node02:2181,node03:2181 --reassignment-json-file /opt/confluent-data/kafka-data/increase-replication-factor.json --execute

结果：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjA3MDQ3Mw_size_16_color_FFFFFF_t_70 1][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjA3MDQ3Mw_size_16_color_FFFFFF_t_70]: /images/20221123/4a00b43973b141568eae5d2218770936.png
[20201008143516615.png]: /images/20221123/842bc32d37bc4931b7631ccdc709e823.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjA3MDQ3Mw_size_16_color_FFFFFF_t_70 1]: /images/20221123/50b6159bab1b49aaa92cab36b388289b.png