用于管理kafka集群的python库(主题增删、增加分区、重新分配、领导人选举等)

Question

我在互联网上搜索python库来管理kafka操作，如主题的增删改查、分区增量、分区重新分配、领导者选举等，我什么也没找到。

我知道pykafka，kafka-python，但它们用于创建消费者/生产者，我可以使用kazoo进行主题的CRUD，但我不能执行我提到的其他操作。你能推荐一些用来管理kafka集群的python库(如果有)吗？

谢谢!

Answer 1

PyKafka包括一个用于创建主题here的命令行界面。我不确定你所说的“分区增量”是什么意思。对使用者的分区分配是由PyKafka的成员协议实现在内部处理的。据我所知，领导选举不是由客户触发的。

我不知道有什么python库可以完全复制与Kafka捆绑在一起的CLI工具的功能，但PyKafka非常接近。