gpt4 book ai didi

python - Kafka-python 获取主题的分区数

转载 作者:太空狗 更新时间:2023-10-29 22:18:49 31 4
gpt4 key购买 nike

我正在使用:https://github.com/mumrah/kafka-python作为 Python 中的 kafka api。我想获取指定主题的分区数。我该怎么做?

最佳答案

可能是一个稍微简单的解决方案,但是:

from kafka import KafkaClient

client = KafkaClient('SERVER:PORT')
topic_partition_ids = client.get_partition_ids_for_topic(b'TOPIC')
len(topic_partition_ids)

在 Python 3.4.3/kafka-python 0.9.3 上测试

关于python - Kafka-python 获取主题的分区数,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29612228/

31 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com