kafka AdminClient获取kafka版本

Question

有没有办法以编程方式获取kafka集群的版本？比如，使用 AdminClientAPI​​。

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

Answer 1

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

目前正在开发一个 KIP，将该功能添加到 AdminClient：KIP-483：在 Admin Client 中添加代理版本 API，以便在未来版本中可用。

与此同时，您可以尝试一些解决方法：

• 用于describeConfigs()查找inter.broker.protocol.version代理的配置。如果返回2.2-IV1，则意味着代理至少运行2.2。

• 检查 ApiVersions 响应。启动时，客户端发送 ApiVersions 请求，并将响应写入日志（INFO 级别）。或者手动发送ApiVersions，制作这样的请求非常容易，因为它是一个空主体。然后您可以使用https://cwiki.apache.org/confluence/display/KAFKA/Kafka+APIs识别代理版本