个人中心
文章发布
退出
作者热门文章
- html - 出于某种原因，IE8 对我的 Sass 文件中继承的 html5 CSS 不友好？
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景？
29
4
有没有办法以编程方式获取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。 关于apache-kafka - kafka AdminClient 获取 kafka 版本，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/57002941/
29
4
0
我一直在尝试使用 AdminClient 来获取消费者的滞后，但是 adminClient.listGroupOffsets("foo");返回一个空指针 NullPointerException。
希望我能解释一下! 我正在启动一个dockerized java spring boot应用程序，它将连接到单个dockerized Kafka实例。 为此，我在 docker-compose 文件中
我是 Kafka 的新手，正在尝试使用 AdminClient用于管理在我的本地机器上运行的 Kafka 服务器的 API。我的设置与 quick start 中的完全相同Kafka 文档的部分。唯一
用于通过 Perf Mbean 监控 WebSphere 应用程序服务器 我选择了 RMI 或 SOAP 连接器端口来从 Adminclient 获取连接。如以下代码所示， Properties lo
我一直在尝试使用 AdminClient 类获取所有消费者组，但有时我会遇到运行时异常。我正在使用带有 Angular 前端的 Spring Boot 应用程序，并发出 http 请求来调用此方法:
我需要在生成事件之前提供 kafka 主题的存在，并且默认的 kafka 主题自动创建是不够的。我决定使用 AdminClient 类，但我担心并发问题。 没有关于线程安全的信息AdminClient
AdminClient 的 API 包含方法 describeLogDirs两个签名都需要“经纪人列表”。引号中的表达式正是 javadoc 所描述的内容 - 不多了。 我必须提供什么作为该函数的参数
有没有办法以编程方式获取kafka集群的版本？例如，使用AdminClient应用程序接口(interface)。 我想在消费者/生产者应用程序中识别 kafka 集群的版本。 最佳答案 目前无法检索
我想创建和使用 java 实用程序来获取信息并创建/修改/删除主题。 要创建实用程序，我正在尝试 this link 中的示例 这就是我在代码中设置属性的方式: Properties adminCon
我经历过使用 RMI 连接器的 WebSphere AdminClient 的奇怪行为。 在 WAS 7 独立服务器(服务器名称:server1)上部署一个测试 Web 应用程序(一个 servlet
Eclipse 中的 Axis 插件是否使用 AdminClient 来部署 Web 服务？我正在更改 WEB_INF/some/name/space/deploy.wsdd 下的 deploy.ws
我正在编写一个工具来验证 Web 应用程序的 WebSphere 设置。我希望能够通过 java AdminClient 对象远程连接到服务器来查找 WebSphere 变量(所有范围)的所有可能值。
我对使用 AdminClient createTopics 创建的主题有疑问. 在我的应用程序中，我有以下顺序: 创建具有 1 个分区的新主题，使用 AdminClient.createTopics
我是一名优秀的程序员,十分优秀！