程序员经验分享-hwhale

Apache Kafka：TimeoutException 然后什么都不起作用

2023-12-30

我正在尝试将消息从生产者发送到另一个 DC 中的 kafka 节点。 生产者和消费者都设置为默认0.10.0.0配置和消息大小都不是那么小（大约 500k）。 大多数情况下，我在发送消息时会遇到以下异常：

org.apache.kafka.common.errors.TimeoutException：包含 1 条记录的批次由于在向主题 0 的代理请求元数据时超时而过期 org.apache.kafka.common.errors.TimeoutException：无法在配置的最大阻塞时间 60000 毫秒内分配内存。

之后，不再传输任何消息（甚至不会调用剩余消息的回调）。


只是想插话，因为我今天收到了完全相同的错误。我尝试增加request.timeout.ms，减少batch.size，甚至设置batch.size为零。然而，没有任何效果。

原来是因为服务器无法连接到 10 个 Kafka 集群节点之一。所以，我看到的是抛出了一些不适当的异常。顺便说一句，如果有必要的话，我们正在使用 Kafka 0.9.0.1。

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

ApacheKafka

Apache Kafka：TimeoutException 然后什么都不起作用 的相关文章

随机推荐

  • iPhone 接近传感器

    iPhone SDK 可以利用 iPhone 的接近传感器吗 如果是这样 为什么没有人利用它们 我可以想象一些不错的用途 例如 在赛车游戏中 您可以将手指放在接近传感器上 而不是用拇指占据屏幕空间 当然 如果这是您唯一的选择 那么 iPod

  • 依赖项中的共享文档文件导致事务错误

    我最近在桌面上安装了 Fedora 24 Workstation 并且能够毫无问题地安装所有内容 直到我尝试安装 steam 来自 rpmfusion 和 wine steam 和 wine 都具有 32 位库的依赖项 这些库已安装在 64

  • JVM 以编程方式获取堆中最大的对象

    How 以编程方式 从java应用程序 代理中 我是否获得堆中最大对象的 实时 摘要 包括它们的实例计数和大小 与分析器的做法类似 例如 下面是 JProfiler 的屏幕截图 通常 我曾经在真正需要的情况下使用堆转储 但现在我想弄清楚分析

  • 在 Azure DevOps Pipelines (YAML) 中通过手动批准跳过阶段

    对于我们的 Terraform 部署 我们使用具有 3 个阶段的 Azure DevOps 管道 plan 申请 手动审批 test 对于应用阶段 我们使用具有手动批准 检查 环境的部署作业 如果计划阶段没有显示任何变化 我们希望 跳过 应

  • TDD 和测试优先开发（或测试优先编程）之间有区别吗？

    这两个想法对我来说听起来非常相似 但可能存在细微的差异 或者是完全相同的事情 但以不同的方式解释 TDD 和测试优先开发 编程之间有什么关系 驱动因素是什么是有区别的 您是否对类 或系统 当然 这可以在不同的规模上发生 应该是什么样子有一个

  • Dockerfile 中的 VOLUME 命令有什么作用？ [复制]

    这个问题在这里已经有答案了 我很难理解 VOLUME https docs docker com engine reference builder volume https docs docker com engine reference

  • 如何使用 VBA 将数据透视表过滤器放置在彼此上方？

    基本上 我有多个选项卡放在一起 每个选项卡都有多个数据透视表 每个数据透视表内置多个过滤器 这些需要可见才能确认您所看到的数据 因为非开发人员不知道如何访问或了解VBA代码 我想要的 数据透视表过滤器以列表形式相互重叠 我目前得到的 这是代

  • 如何在 Android 中获取可用的屏幕宽度和高度

    I m creating an app where I really need to know the correct screen dimensions Actually I know how to do that but a probl

  • ModuleNotFoundError：在虚拟环境中运行服务器时没有名为“django”的模块

    我是 python 学习的新手 在学习了 python 基础知识之后 我开始学习 python Web 框架 Django 为了这 安装 python 3 7 后 我按照以下步骤在 Windows 上安装 django 首先我打开cmd命令

  • 如何使用 Eclipse IDE 重新部署 Web 应用程序

    我是 Eclipse 新手 我使用 Tomcat 作为运行时服务器 但每次修改 jsp 页面时 Eclipse 仍然显示旧的页面 只是想知道如何重新部署应用程序以便反映更改 Eclipse 面向 Java EE 开发人员的 Eclipse

  • Node.js 中的安全随机令牌

    In 这个问题 https stackoverflow com questions 8838624 nodejs send email on registration 8842959 8842959Erik 需要在 Node js 中生成一

  • Sequelize，MySQL - 使用 JSON 列值过滤表中的行

    需要帮助了解如何使用 Sequelize 使用嵌套值过滤 MySQL 表 JSON 列中的行 文档中没有它 仅针对 PostgreSQL 和 MSSQL ref http docs sequelizejs com manual tutori

  • _Unwind_Resume 的多个定义

    一段时间以来 我一直在使用我编写的一小部分文件 以便更轻松地与 WinAPI 进行交互 虽然 当我想重用它们时 不断移动文件 等待它们重新编译等变得很痛苦 我最终决定将它们放入 DLL 中 然后就完成了 但我得到了一个每次我尝试使用该库时都

  • 绑定 ToConstant 和调用 InSingletonScope 是多余的吗？

    嗯 这个问题从标题就已经很简单地说明了 对于局部变量factory var factory Fluently Configure 这两行是否等价 Bind

  • 如何使用 Laravel 的 Eloquent 实现单表继承？

    目前我有一个名为的模型类Post class Post extends Eloquent protected table posts protected fillable array user id title description vi

  • iOS开发-无限关卡的uitableview

    我的 XML 数据采用具有可变深度的树结构 有时 数据馈送的深度可能为 50 级 有时则为 5 级 我应该为视图使用哪个 iOS UI 组件 我看到了 uitableview 但在打印叶节点之前它似乎只支持 1 层树 我还应该考虑另一个 U

  • React-native 调试 apk

    如何获取react native应用程序的调试版本 对于 apk 的发布版本 我使用 gt cd android gradlew assembleRelease 生成的 apk 将存储在 app build outputs apk 中 有没

  • 使用 Proc#call 时为自己提供价值

    当在 Ruby 中使用 Proc call 调用 lambda 函数时 self始终以定义函数时的值结束 而不是调用函数时的值 例如 p lambda self class Dummy def test p call end end d D

  • 使用 HTML5 和/或 jQuery 将文件上传到 WCF 服务

    我正在尝试仅使用 HTML5 和 JavaScript jQuery 将文件上传到我的 WCF 服务 WCF 服务是从 Windows 服务而不是 IIS 自托管的 因此我认为我无法使用 php 或 aspx 上传处理程序 这些文件是二进制

  • Apache Kafka：TimeoutException 然后什么都不起作用

    我正在尝试将消息从生产者发送到另一个 DC 中的 kafka 节点 生产者和消费者都设置为默认0 10 0 0配置和消息大小都不是那么小 大约 500k 大多数情况下 我在发送消息时会遇到以下异常 org apache kafka comm

热门标签