小贝子编程

使用 KafkaItemReader 从特定日期范围内的 Kafka 主题获取记录(用于读取 kafka 流的 Spri

本文关键字：记录获取用于读取 Spri 流的 kafka KafkaItemReader 日期 Kafka 范围内 spring-batch kafka-consumer-api
更新时间 : 2023-09-17
英文 : Fetch the records from Kafka topic within specific date range using KafkaItemReader (Spring batch job to read kafka streams)

有没有办法在春季批处理作业中读取 Kafka 主题中的记录，该作业在特定日期范围内使用 KafkaItemReader？

目前不支持，您需要编写自定义阅读器或使用项目处理器来过滤掉超出范围的消息(过滤数据是项目处理器的典型用例：https://docs.spring.io/spring-batch/docs/4.2.x/reference/html/readersAndWriters.html#filteringRecords(

最新更新

属性错误： 'DataFrame'对象没有属性'assign'
如何在每次在DirectoryInfo.GetFiles()中加载新文件时执行操作?
HTML中的Javascript在Angular中不起作用
如何在firebase中调度大约每整小时运行一次的函数?
Uncaught TypeError:不能访问数组上字符串类型的偏移量
Switch(Select)在TRANSFORM和Select之间工作吗?
MySQL SELECT查询工作，但具有相同WHERE子句的UPDATE查询不工作
drupal 10 localhost站点:如何在安装和注销后访问登录页面
Flutter原生启动画面图像未出现- Flutter (Dart)
用另一个远程分支覆盖一个远程分支
邮递员说"The route api...could not be found."(拉拉维尔)
Firebase Messaging项目Google Analytics升级失败
在初始页面加载时未应用FacetWP查询顺序数组设置
GitHub邀请过期吗?
使用AWS秘密管理器端点的安全组
如何做基于名称和值的点击事件？
在容器和主机上创建具有相同Linux用户id的用户
Firebase身份验证在部署后不工作.扑动Web应用程序显示空白的白色屏幕
AWS Client VPN Access Public URL/IP
python dict get方法即使key在dict中也运行第二个参数
如何在Python中使用每周时间序列
Scss函数没有返回计算值
如何使用conduit获取一个lazy ByteString并将其写入文件(在恒定内存中)
c -内存分配器-简单隔离存储:你如何从它的地址推断分配块的大小?
获取JSON格式的Discord PY对象
如何为作为prop传入的React组件设置类型
在c++中使用new时是否按顺序分配内存?
你可以暂时复制谷歌云图像文件在Python?
PHP cURL 一个帖子但两次(双)它是相同的数据到数据库与 API
405 (Method Not Allowed)错误的ajax在Laravel 8

使用 KafkaItemReader 从特定日期范围内的 Kafka 主题获取记录(用于读取 kafka 流的 Spri

相关内容

最新更新

热门标签：