gpt4 book ai didi

apache-kafka - kafka AdminClient 获取 kafka 版本

转载 作者:行者123 更新时间:2023-12-04 13:18:38 30 4
gpt4 key购买 nike

有没有办法以编程方式获取kafka集群的版本?例如,使用AdminClient应用程序接口(interface)。

我想在消费者/生产者应用程序中识别 kafka 集群的版本。

最佳答案

目前无法检索代理正在运行的 Kafka 版本。

正在进行 KIP 以将该功能添加到 AdminClient:KIP-483: Add Broker Version API in Admin Client以便在将来的版本中可用。

同时,您可以尝试一些解决方法:

  • 使用 describeConfigs() 找到 inter.broker.protocol.version经纪人的配置。如果返回 2.2-IV1 ,这意味着代理至少运行 2.2。
  • 检查 ApiVersions 响应。客户端启动时发送 ApiVersions 请求,响应写入日志(在 INFO 级别)。或手动发送 ApiVersions ,很容易制作这样的请求,因为它是一个空的主体。然后您可以使用 https://cwiki.apache.org/confluence/display/KAFKA/Kafka+APIs 识别代理版本
  • 关于apache-kafka - kafka AdminClient 获取 kafka 版本,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57002941/

    30 4 0
    Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
    广告合作:1813099741@qq.com 6ren.com