用于管理 kafka 集群的 python 库（主题 CRUD、增加分区、重新分配、领导选举等）

Question

我在互联网上搜索了 python 库来管理 kafka 操作，例如主题上的 CRUD、分区增量、分区重新分配、领导者选举等。我没有找到任何东西。

我知道 pykafka、kafka-python，但它们用于创建消费者/生产者，我可以使用 kazoo 对主题进行 CRUD，但我无法执行我提到的其他操作。你能推荐任何用于管理 kafka 集群的 python 库（如果有的话）吗？

谢谢！

Answer 1

PyKafka 包含一个用于创建主题 here 的 CLI。我不确定“分区增量”是什么意思。分配给消费者的分区由 PyKafka 的成员协议实现在内部处理。据我所知，领导者选举不能由客户触发。

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