程序员经验分享-hwhale

有什么方法可以检查 kafka 是否已从 kafka-net 启动并运行

2023-12-31

我正在使用 kafka-net 客户端向 kafka 发送消息。我只是想知道是否有任何方法可以检查 kafka 服务器是否启动并且可以接收消息。我关闭了kafka，但生产者已成功创建，而SendMessageAsync只是冻结了相当长的时间。我尝试过超时，但它没有改变任何东西。我使用kafka-net 0.9 当kafka服务器启动并运行时它工作得很好


Broker的id已在zookeeper中注册（/brokers/ids/[brokerId]）作为临时节点，它允许其他经纪人和消费者检测故障。（现在健康的定义相当幼稚。如果在 zk 中注册/brokers/ids/[brokerId]经纪人是健康的，否则就是死的）。

只要代理的会话存在，zookeeper 临时节点就存在 积极的。

您可以通过 ZkUtils.getSortedBrokerList(zkClient) 检查经纪人是否已启动，它返回以下所有活动经纪人 ID/brokers/ids

import org.I0Itec.zkclient.ZkClient;

ZkClient zkClient = new ZkClient(properties.getProperty("zkQuorum"), zkSessionTimeout, zkConnectionTimeout,ZKStringSerializer$.MODULE$);
ZkUtils.getSortedBrokerList(zkClient);

参考
Zookeeper 中的 Kafka 数据结构 https://cwiki.apache.org/confluence/display/KAFKA/Kafka+data+structures+in+Zookeeper

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

ApacheKafka

有什么方法可以检查 kafka 是否已从 kafka-net 启动并运行 的相关文章

随机推荐

  • Puppeteer C#：连接到正在运行的 Chrome 实例

    我目前正在运行 PuppeteerSharp v1 19 0 来启动浏览器并抓取网页 需要能够连接到现有的 chrome 实例并自动执行任务 我怎样才能实现这个 PuppeteerSharp 通过以下内容 我可以使用 PuppeteersS

  • 如何使用 Material Design 图标作为 CSS 背景图像值？

    我正在使用 MaterializeCSS 所以我已经有了可用的材料设计图标 我怎样才能将它们用作background image我的 CSS 代码中的值 实际上是 SASS 如果您使用 Material Icons Font 您可以使用的另

  • WPF 控件继承

    我读过一个blog http wekempf spaces live com blog cns D18C3EC06EA971CF 508 entry下面这句话 WPF的第一条规则 避免控制继承 我在其他地方也看到过类似的事情 但是 我无法理

  • 使用格式化输出自动扩展Python列表[重复]

    这个问题在这里已经有答案了 有谁知道是否有办法在Python中自动扩展列表 以逗号分隔 我正在编写一些使用 MySQLdb 库的 Python 代码 并且尝试使用某些键值动态更新 MySQL 数据库中的行列表 例如 在下面的代码中 我希望将

  • 数据库备份/恢复过程

    SQL Server 上的大型数据库或数据库集合的备份和恢复过程对于灾难和恢复目的非常重要 然而 我还没有找到一个强大的解决方案来保证整个过程尽可能高效 100 可靠 易于维护和跨多个服务器进行配置 微软的维护计划似乎还不够 我使用过的最佳

  • ASP.NET/C# - 检测其他服务器的文件大小？

    我正在尝试查找服务器上文件的文件大小 以下代码是我从this guy http www thejackol com 2005 06 11 aspnet get file size 为您自己的服务器完成此操作 string MyFile ph

  • 在 Android Studio 中收到“Gradle 同步失败：连接重置”

    在 Android Studio 中创建一个简单的项目时 我收到此错误 供您参考的日志文件 2018 08 13 10 56 47 583 e 1024 b02 INFO e project sync GradleSyncState Sta

  • 如何使用 XSLT 删除默认命名空间并保留其余命名空间？

    我有一个 XML 文件 其中包含默认命名空间和空命名空间 需要将其删除 同时保留其余命名空间 Input

  • 如何检查鼠标点击事件是模拟的还是原生的？ （非 jQuery 方式）

    使用 jQuery 就很容易了 纯 JavaScript 则不然 至少要找出如何做到这一点并不容易 if event clientX event clientY 提供某种检测 但不是 100 准确 There is一种方式 但恕我直言 这是

  • Python urllib 属性错误

    import urllib request fhand urllib request urlopen http www python org for line in fhand print line decode strip 这段代码不起作

  • Xcode4中“ipad的升级目标”在哪里

    我正在运行 Build 4A304a 但我在 Xcode 中找不到它 也无法在互联网上找到它的任何参考 任何帮助将不胜感激 在项目导航器中选择您的项目 单击您的目标 然后单击 摘要 选项卡 您可以将 iOS 应用程序目标切换为通用 这是一个

  • 将 Eigen::VectorXd 类型转换为 std::vector

    他们有很多相反的链接 但在我的具体情况下 我无法找到从 Eigen Matrix 或 Eigen VectorXd 获取 std vector vector

  • 如何避免在 C 或 C++ #include 指令中显式声明目录路径？

    我正在制作一个模拟器并编写了很多文件和标头 问题是每当我包含一个文件时 我都会给出特定文件的相对路径 例如 我的应用程序中的典型代码将像这样开始 ifndef AI H define AI H include

  • 从筛选列表和循环中将多个文件附加到 Outlook 电子邮件 [关闭]

    Closed 这个问题需要调试细节 help minimal reproducible example 目前不接受答案 我有一份包含发票数据的客户列表 一个客户可能有一行或多行数据 我已经用多个代码组装了一个宏脚本来过滤掉客户 根据电子邮件

  • iOS 构建/ipa 创建不再通过命令行进行

    Overview 我们的命令行构建 构建和创建 ipa 不再起作用 iTunesConnect 已开始拒绝使用CODE SIGN RESOURCE RULES PATH构建设置 如果我们在没有设置的情况下进行构建 PackageApplic

  • Canny 边缘算法中只需要一条边

    当我使用精明边缘算法时 它会按预期产生与粗彩色线相对的 2 条边缘 但我只想显示一条边缘 以便使我的直线和曲线检测算法变得不那么复杂 关于如何做的任何想法让这一切发生 这是代码 bool CannyEdgeDetection DataStr

  • 调整大小触发函数一次，直到条件为 True 或 False

    我正在努力寻找解决方案 请需要一些帮助 这是一个简单的示例 function ifTrueInitiateOnce console log True function should be initiated triggered Once f

  • 获取当前文件的路径

    如何获取 java文件所在的目录 我不想使用System getProperty user dir 因为这给了我可执行文件的目录 而不是包含这行代码的 java 文件的目录 我需要这个 因为我正在开发一个 JSP Web 应用程序 并且 J

  • Swift 3 中的 NSBatchDeleteRequest 仅适用于 iOS 10？

    因此 将我的代码迁移到Swift 3让我有点卡住了 它似乎NSBatchDeleteRequest需要iOS 10现在 我构建代码的唯一方法是使用以下代码片段 func removeAllChargerData Remove all cha

  • 有什么方法可以检查 kafka 是否已从 kafka-net 启动并运行

    我正在使用 kafka net 客户端向 kafka 发送消息 我只是想知道是否有任何方法可以检查 kafka 服务器是否启动并且可以接收消息 我关闭了kafka 但生产者已成功创建 而SendMessageAsync只是冻结了相当长的时间

热门标签