程序员经验分享-hwhale

Kafka Streams代理连接超时设置

2024-02-13

我们正在使用 kafka-streams 2.3.1，我刚刚注意到，如果代理关闭，流应用程序似乎会满足于尝试永远尝试连接。

new KafkaStreams(createTopology(), properties()).start()

 o.apache.kafka.clients.NetworkClient - [AdminClient clientId=test] Connection to node -1 (broker/127.0.0.1:9092) could not be established. Broker may not be available.

发生这种情况时流状态为 REBALANCING，因此没有好方法来确定连接是否刚刚断开。

有没有办法为代理连接尝试设置超时或重试次数？


不幸的是，这个问题没有好的解决方法。该问题实际上是消费者问题，因为消费者只是尝试重新连接，但并未向 Kafka Streams 显示其内部状态。此外，也不可能将消费者配置为在某个时刻放弃。

有一个KIP可以向Kafka Streams添加“DISCONNECTED”状态，但是最近没有太大进展......这很复杂......https://cwiki.apache.org/confluence/display/KAFKA/KIP-457%3A+Add+DISCONNECTED+status+to+Kafka+Streams https://cwiki.apache.org/confluence/display/KAFKA/KIP-457%3A+Add+DISCONNECTED+status+to+Kafka+Streams

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

ApacheKafka

apachekafkastreams

Kafka Streams代理连接超时设置 的相关文章

随机推荐

  • R中glmnet中的岭回归；使用 glmnet 包计算不同 lambda 值的 VIF

    我有一组多重共线性变量 我正在尝试使用岭回归来解决这个问题 我正在使用glmnetR 中的包 alpha 0 用于岭回归 library glmnet 我有一系列 lambda 值 并且我通过 cv glmnet 选择最佳 lambda 值

  • ListView 列的最小宽度

    我怎样才能指定MinWidthWPF 中的 Listview 列 此代码使用 Thumb 控件 它将阻止用户仅将标题拖动到指定的宽度 将其添加到您的 WPF 中

  • 如何在 React 中实现 Cloudinary 上传小部件？

    我正在尝试在我的 React 应用程序中使用 Cloudinary 上传小部件 但我遇到了问题 运行项目时 上传小部件会立即出现 但是当关闭并再次打开时 应用程序崩溃并显示以下消息 widget open 不是一个函数 Note 上传工作正

  • 如何使用异步回调进行同步操作？

    如何用异步函数进行同步操作 class MyClass static let shared MyClass let operationQueue OperationQueue let dispatchGroup DispatchGroup

  • 隐式转换的 gcc 警告标志

    我最近遇到了一个与下一个类似的错误 double getSomeValue return 4 0 std string str str getSomeValue 正如您所看到的 很容易发现问题 但在大型代码库中getSomeValue 与调

  • 如何在CSS中动态调整图像大小？

    我有一个简单的 html css 页面 上面有 3 个图像 我试图根据浏览器窗口的大小调整页面大小 现在 我在一个 div 中有 3 个图像 其高度设置为周围容器的百分比 并且图像设置为 height 100 和 width auto 现在

  • 在 Ruby 中向类添加实例变量

    如何将实例变量添加到已定义的类中runtime 然后从类外部获取并设置其值 我正在寻找一种元编程解决方案 它允许我在运行时修改类实例 而不是修改最初定义该类的源代码 一些解决方案解释了如何在类定义中声明实例变量 但这不是我要问的 Ruby

  • WinDbg——TraceListener 和饱和线程池

    我有一个多线程 NET Windows 服务 它间歇性地挂起 可能每两周 24 7 运行一次 当发生挂起时 线程池完全饱和 因为对我们的自定义跟踪侦听器的调用由于某种原因开始阻塞 根据 Windbg 的说法 有问题的代码中没有任何锁 也没有

  • SwiftUI 更新地图区域导致有关修改状态的警告

    我有一个使用 iOS 14 中新的 SwiftUI Map 的项目 我希望能够动态更新地图中心的位置 当您点击 缩放 按钮 然后点击 位置 按钮时 地图可以正常工作并重新以伦敦为中心 但是 如果您只是点击位置按钮 它会重新以伦敦为中心 但会

  • Sublime Text - 转到行和列

    目前 转到行快捷方式 Windows Linux 中的 CTRL G 仅允许导航到特定行 最好选择允许在逗号后指定列号 例如 30 11转到第 30 行 第 11 列 是否有任何插件或自定义脚本可以实现此目的 Update 3 这是现在Su

  • 使用Python在NLP中的命名实体识别中提取人名

    我有一个句子需要单独识别人名 例如 sentence Larry Page is an American business magnate and computer scientist who is the co founder of Go

  • 从本机应用程序到网站的切换不起作用

    我的设备 iPad Mini 最新 iOS 8 dp5 Macbook Air 优胜美地 dp5 我在上述两个设备之间进行了切换 Safari 邮件 消息 日历等所有切换都没有问题 我什至可以在 Air 上的网站和 iPad 上的本机应用程

  • 如何在qt中获取联系人列表

    我使用此代码并仅获取一个人的联系方式 contactManager new QContactManager QList

  • 如何从 C++ 打开 URL？

    如何从我的 C 程序中打开 URL 在红宝石中你可以做 x open https google com C 中的等价物是什么 我想知道是否有一个独立于平台的解决方案 但如果没有 我更喜欢 Unix Mac 这是我的代码 include

  • ReadToEnd 之后关闭 StreamReader

    在构造中调用 ReadToEnd 方法后是否可以以某种方式关闭 StreamReader 如下所示 string s new StreamReader filename Encoding UTF8 ReadToEnd 任何具有相同语义的替代

  • Visual Studio 2010/2012 Git 插件

    我正在寻找 git 与 VS 2010 2012 集成的建议 允许开发人员使用基本操作 提交 推送 拉取 切换分支 标记 有几个 Git 源代码控制提供程序 http visualstudiogallery msdn microsoft c

  • 在多层应用程序中，是否应该允许客户端将自己的 linq 表达式发送到服务器？

    理由 HQL 和 NH 标准是 NHibernate 特定的构造 因此它们是服务器端 DAL 实现细节 我不希望它们 泄漏 到客户端 因此 我们的客户端提供LINQ表达式供服务器处理 对我来说似乎合理 但是有些人不这么认为 所以我想知道为什

  • 简单 XML 框架反序列化的异常

    我在反序列化已成功序列化的 XML 文件时遇到问题简单的 XML 序列化 http simple sourceforge net 框架 simpleframework org 有一个例外 http simple sourceforge ne

  • Firefox 扩展在 main.js 文件中包含脚本

    我正在为 Firefox 编写扩展 但在将脚本包含到 main js 后台 文件中时遇到问题 就我而言 我想包括 jquery js 和 config js 但我不知道如何正确执行它 在我的 chrome 扩展中 我只是在清单文件上执行此操

  • Kafka Streams代理连接超时设置

    我们正在使用 kafka streams 2 3 1 我刚刚注意到 如果代理关闭 流应用程序似乎会满足于尝试永远尝试连接 new KafkaStreams createTopology properties start o apache k

热门标签