如何为主题创建或设置分区数？答案

【问题标题】：How to create or set number of partitions for a topic?如何为主题创建或设置分区数？
【发布时间】：2021-02-03 01:52:39
【问题描述】：

我正在使用python 3.6.8 和kafka-python=2.0.2

有没有办法从 python 代码中设置主题的分区数？

我的生产者代码看起来：

producer = KafkaProducer(bootstrap_servers=['localhost:9092'],
                             value_serializer=lambda x:
                             dumps(x).encode('utf-8'))

producer.send("RANDOM_NEW_TOPIC", value={'test'})

我查看了手册，但看不到如何更新主题的分区数

【问题讨论】：

标签： python-3.x apache-kafka apache-kafka-streams kafka-producer-api

【解决方案1】：

我们可以使用 Kafka Admin CreatePartitions API 来增加分区数量。下面展示了如何将主题topic1的分区数增加到4

from kafka import KafkaAdminClient
from kafka.admin.new_partitions import NewPartitions

client = KafkaAdminClient(bootstrap_servers='localhost:9092')

rsp = client.create_partitions({
    'topic1': NewPartitions(4)
})
print(rsp)

【讨论】：