热门标签
热门文章
- 1Kali Linux数字取证与逆向工程_kali中逆向分析工具
- 2CleanMyMac X4.15.2中文直装板免费下载及CleanMyMac X2024破解激活码分享_cleanmymac免费版
- 3零基础Python学习指南：2024年最详细全方向学习路线图，助力初学者高效成长，避免弯路！_python学习路线图
- 435岁难找工作，40岁没人要：年长的程序员都去哪里了？不要让环境同化了年轻的程序员！(1)_老程序员都干嘛去了
- 5基于leaflet 的高德离线地图/瓦片地图，以及简单的自定义样式、限制可视范围、右键菜单_高德瓦片地图
- 6深度学习入门——神经网络
- 7Postman使用指南①网页版使用
- 8微信小程序毕业设计-微信阅读网站系统项目开发实例(附源码+演示视频+LW)_微信小程序项目设计说明书怎么写csdn
- 9深度剖析服务发现组件Netflix Eureka
- 10基于YOLOv7算法的高精度实时行人摔倒检测识别系统（PyTorch+Pyside6+YOLOv7）_基于yolov7老人跌倒检测报警系统
当前位置: article > 正文
【Flink】kafka INVALID_PRODUCER_EPO send data to Kafka old epoch newer producer same transactionalId_flink 写入 kafka old epoch
作者：盐析白兔 | 2024-07-12 21:51:31
赞
踩
flink 写入 kafka old epoch
1.场景1
问题重复：【Flink】kafka FlinkKafkaException send data to Kafka old epoch newer producer same transactionalId
网友的一个问题。flink可不可以一个流进行多种处理，比如从一个kafka读出数据，进行订单的按日统计，按小时统计，再按人统计，实际上我想要输出的是多条，例如说每小时的GMV统计是一个输出保存到redis，按日统计的又是一个输出保存在redis
比如如下代码
我自己跑的时候也觉着没问题，现在测试的时候老是不断重启，总是报kafka Producer attempted an operation with an o
推荐阅读
相关标签
