kafka AdminClient获取kafka版本
kafka AdminClient获取kafka版本
提问于 2019-07-12 16:18:29
有没有办法通过编程获取kafka集群的版本？例如使用AdminClient应用程序接口。
我想在消费者/生产者应用程序中识别kafka集群的版本。
回答 2
Stack Overflow用户
发布于 2019-07-12 16:42:25
目前，没有办法检索正在运行的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
标识代理版本
Stack Overflow用户
发布于 2019-07-12 16:41:25
你可以在你的消费者/生产者代码中使用AppInfoParser.getVersion();。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/57002941
复制相关文章
相似问题
腾讯云开发者
