当前位置： 首页 > news >正文

解决：Flink向kafka写数据使用Producer精准一次（EXACTLY_ONCE）异常

news 来源：原创 2024/9/20 7:27:08 
在使用flink向kafka写入数据报错：Caused by: org.apache.kafka.common.KafkaException: Unexpected error in InitProducerIdResponse; The transaction timeout is larger than the maximum value allowed by the broker (as configured by transaction.max.timeout.ms).

这是因为事务超时值超过了Kafka代理允许的最大值。具体来说，配置的transaction.timeout.ms超过了代理的transaction.max.timeout.ms配置

解决

在使用EXACTLY_ONCE的时候需要增大transaction.max.timeout.ms的值

修改参数

改完之后再重新跑就可以跑通了

相关文章：

  • 北京网站建设多少钱？
  • 辽宁网页制作哪家好_网站建设
  • 高端品牌网站建设_汉中网站制作
  • 初学者必看的 3 个 Python 小项目
  • Oracle PL/SQL 循环批量执行存储过程
  • LT7911UX 国产原装 一拖三 edp 转LVDS 可旋转 可缩放
  • 汽车零配件行业看板管理系统应用
  • 算法简介：什么是算法？——定义、历史与应用详解
  • 使用 Vue.js 和 Element Plus 实现自动完成搜索功能
  • 【MySQL】6.表的增删查改(CURD)
  • Git协作
  • 预测算法面试
  • 【ARMv8/v9 GIC 系列 5.6 -- GIC 超优先级中断详细介绍】
  • mysql的事务,你弄懂了吗？（Innodb）
  • R语言学习笔记3-基本类型篇
  • DR模式介绍
  • C++20中的基于范围的for循环(range-based for loop)
  • leetcode165.解密数字
  • 《剑指offer》分解让复杂问题更简单
  • 【402天】跃迁之路——程序员高效学习方法论探索系列（实验阶段159-2018.03.14）...
  • 【技术性】Search知识
  • leetcode46 Permutation 排列组合
  • 基于 Babel 的 npm 包最小化设置
  • 前端面试题总结
  • 如何借助 NoSQL 提高 JPA 应用性能
  • 我这样减少了26.5M Java内存！
  • 在Mac OS X上安装 Ruby运行环境
  • Linux权限管理(week1_day5)--技术流ken
  • 阿里云ACE认证之理解CDN技术
  • 微龛半导体获数千万Pre-A轮融资，投资方为国中创投 ...
  • ​LeetCode解法汇总307. 区域和检索 - 数组可修改
  • #define MODIFY_REG(REG, CLEARMASK, SETMASK)
  • #pragma multi_compile #pragma shader_feature
  • #我与Java虚拟机的故事#连载02：“小蓝”陪伴的日日夜夜
  • (06)Hive——正则表达式
  • （10）ATF MMU转换表
  • （10）工业界推荐系统-小红书推荐场景及内部实践【排序模型的特征】
  • （C）一些题4
  • （Java实习生）每日10道面试题打卡——JavaWeb篇
  • （python）数据结构---字典
  • （二十四）Flask之flask-session组件
  • （附源码）spring boot智能服药提醒app 毕业设计 102151
  • （附源码）ssm航空客运订票系统 毕业设计 141612
  • (回溯) LeetCode 77. 组合
  • （六）Hibernate的二级缓存
  • （论文阅读22/100）Learning a Deep Compact Image Representation for Visual Tracking
  • （亲测）设​置​m​y​e​c​l​i​p​s​e​打​开​默​认​工​作​空​间...
  • （十三）Flask之特殊装饰器详解
  • （学习日记）2024.01.09
  • (一)Neo4j下载安装以及初次使用
  • （转）LINQ之路
  • *p++,*(p++),*++p,(*p)++区别？
  • *ST京蓝入股力合节能 着力绿色智慧城市服务
  • .Net 6.0 处理跨域的方式
  • .NET Core WebAPI中使用Log4net 日志级别分类并记录到数据库
  • .net framework 4.0中如何 输出 form 的name属性。
  • .NET（C#、VB）APP开发——Smobiler平台控件介绍：Bluetooth组件
  • .NET教程 - 字符串 编码 正则表达式（String Encoding Regular Express）