问题描述
我正在尝试使用python更新集群配置。
log.retention.hours = 120
log.cleanup.policy = compact
我打算使用-KafkaAdminClient。 alter_configs但根据kafka-python文档- “对于broKER资源来说，这是目前无法解决的，因为必须将这些资源发送到特定的代理，而这总是选择负载最小的节点。有关详细信息，请参见源代码中的注释。我们很乐意接受对此进行修复的PR。” >
请提出一个替代方案-我可以使用pykafka.cluster
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）