ansible-kafka-管理员
一个低级的ansible库,用于管理Kafka配置。 它不使用Kafka脚本,而是直接连接到Kafka和Zookeeper(如果需要)以确保创建资源。 无需SSH连接到远程主机。
如果您想增加分区,复制因子,更改主题的参数或轻松管理ACL,则此库非常适合您。
要求
该库使用 , 和库。 使用pip安装它们:
pip install -r requirements.txt
请仅使用那些版本,因为某些更新可能会破坏该库。
目前,该库与0.11.0及更高版本中的Kafka兼容。
它可以与在PLAINTEXT,SASL_PLAINTEXT,SSL和SASL_SSL中配置的Kafka一起使用。
关于Zookeeper ,它还与Kerberos身份验证不兼容,仅与SSL,SASL和DIGEST身份验证兼容。
安装
在您的剧本的requirements.yml中添加以下要求:
---
# from GitHub, overriding the name and specifying a specific tag
- src : https://gi
1