文件名称：kafkameta:用于通过 ZooKeeper 与 Kafka 的元数据交互的 Python 库
文件大小：12KB
文件格式：ZIP
更新时间：2024-08-11 15:30:51
Python
Kafka 元数据 Python 库 该库从 ZooKeeper 中提取有关 Kafka 配置与使用 Kafka 元数据 API 的数据。 从 0.8.2 开始，Kafka 的元数据 API 存在无法反映集群当前状态的问题。 根据https://issues.apache.org/jira/browse/KAFKA-1367 ，未来版本中可能会删除部分 API。 免责声明：这还没有准备好供生产使用，该库仍在发展中，因此我们可能会推动破坏向后兼容性的更改 例子 from kafkameta import KafkaConnection kc = KafkaConnection(hosts=['zk01:2181'], zk_path='/cb/kafka/pingqueue') print kc.topics.keys() print kc.brokers.keys() # load
【文件预览】：
kafkameta-master
----.travis.yml(311B)
----tests()
--------utils.py(3KB)
--------test_broker.py(925B)
--------__init__.py(0B)
--------test_connection.py(863B)
--------README.md(146B)
----LICENSE(11KB)
----requirements.txt(11B)
----setup.py(425B)
----.gitignore(715B)
----README.md(1KB)
----kafkameta()
--------broker.py(737B)
--------__init__.py(266B)
--------connection.py(3KB)
--------partition.py(2KB)
--------topic.py(1KB)