一、背景

设置kafka producer为Semantic.EXACTLY_ONCE会报Unexpected error in InitProducerIdResponse; The transaction timeout is larger than the maximum value allowed by the broker (as configured by max.transaction.timeout.ms)

二、分析并解决

1、查看官方文档，broker最大超时时间是15分钟

2、查看producer默认时间是1小时

broker最大超时时间是15分钟，而producer默认是1小时，不允许超过15分钟，我们解决办法是调整producer的时间：

setProperty("transaction.timeout.ms", "300000");//5分钟

Flink 实战问题（五）：The transaction timeout is larger than the maximum value allowed by the broker相关推荐

Apache Flink 实战教程：CEP 实战(转载)
文章目录原文链接: 一:Flink CEP 概念以及使用场景 1.什么是 CEP 2.Flink CEP 应用场景 3.Flink CEP 原理二:Flink CEP 程序开发 1.Flink C ...
flink实战--水印（watermark）终极总结
扫一扫加入大数据公众号和技术交流群,了解更多大数据技术,还有免费资料等你哦水印(waterMark) 了解水印前需要了解事件时间(eventTime)和处理时间(processTime)的概念,参考 ...
Python入门到实战（五）自动化办公、pandas操作Excel、数据可视化、绘制柱状图、操作Word、数据报表生成、pip install国内镜像下载
Python入门到实战(五)conda使用.pandas操作Excel.数据可视化.绘制柱状图.操作Word.数据报表生成.pip install国内镜像下载 conda使用常用操作配置VS+Co ...
Flink 实战 | 贝壳找房基于Flink的实时平台建设
声明:本文作者刘力云,贝壳找房实时计算负责人.本文来自 2019 年 9 月 21 日 Flink Meetup 北京站贝壳找房刘立云的分享,所有内容版权归其个人及 Flink 中文社区所有. E ...
深入浅出多线程编程实战（五）ThreadLocal详解(介绍、使用、原理、应用场景)
深入浅出多线程编程实战(五)ThreadLocal详解(介绍.使用.原理.应用场景) 文章目录一.ThreadLocal简介二.ThreadLocal与Synchronized区别三.Threa ...
Altium Designer 18 速成实战第五部分 PCB流程化设计常用操作（二）常用PCB快捷键的介绍
Altium Designer 18 速成实战第五部分 PCB流程化设计常用操作(二)常用PCB快捷键的介绍常用系统快捷键----来自PCB联盟网,若侵联系即删. 目录一.组合快捷键如何得来呢? ...
Spring实战第五版源码
Spring实战第五版源码链接:https://pan.quark.cn/s/11a451b1aa84 提取码:uzGW
PyTorch 入门实战（五）——2013kaggle比赛猫狗大战的实现
承接上一篇:PyTorch 入门实战(四)--利用Torch.nn构建卷积神经网络 PyTorch入门实战 1.博客:PyTorch 入门实战(一)--Tensor 2.博客:PyTorch 入门实战 ...
【go实战系列五】 go1.19.2与pkg中error如何wrap与unwrap Errors | 将error进行wrap向上处理思想 | pkg/errors
历史go篇章 [go实战系列一]开篇:在循环中重新定义变量(redefining for loop variable semantics) [go实战系列二]关于切片的基本操作 copy sort a ...
【机器学习】实战系列五——天文数据挖掘实验（天池比赛）
系列文章目录学习笔记: [机器学习]第一章--机器学习分类和性能度量 [机器学习]第二章--EM(期望最大化)算法 [机器学习]第六章--概率无向图模型实战系列: [机器学习]实战系列一--波士顿 ...

Flink 实战问题（五）：The transaction timeout is larger than the maximum value allowed by the broker

一、背景

二、分析并解决

Flink 实战问题（五）：The transaction timeout is larger than the maximum value allowed by the broker相关推荐

最新文章

热门文章