使用Python更新Kafka群集配置

问题描述

我正在尝试使用python更新集群配置。

log.retention.hours = 120
log.cleanup.policy = compact

我打算使用-KafkaAdminClient。 alter_configs但根据kafka-python文档- “对于broKER资源来说,这是目前无法解决的,因为必须将这些资源发送到特定的代理,而这总是选择负载最小的节点。有关详细信息,请参见源代码中的注释。我们很乐意接受对此进行修复的PR。” >

请提出一个替代方案-我可以使用pykafka.cluster

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)