kafka按照时间查询记录

本质是重新开始消费，逐条按时间比较
–from-beginning //表示重头开始读
–property print.timestamp=true //表示显示入kafka时间
使用awk对消费出来的记录进行筛选过滤，比如以下表示对每条消费记录按照“CreateTime:“或者”\t“进行分割，$0表示原始的记录，$1表示分割后的第1个字符串，以下$2为分割后的第二字符串，为入kafka的时间

./kafka-console-consumer.sh --topic topicnamexxx --bootstrap-server 192.168.1.2:9092  --property print.timestamp=true --from-beginning |awk -F 'CreateTime:|\t' '$2>= 1614845604323 && $2 <= 1614845750416 {print $0}'

kafka按照时间查询记录相关推荐

SpringBoot+MyBatisPlus实现前端传递时间查询条件ajax请求后台并回显数据流程整理
场景前端时间选择控件,选择时间后点击搜索,请求后台数据,后台根据时间查询数据库中一天的记录数并回显给前端,前端进行显示. 实现前端页面代码(部分) <div class="ibo ...
oracle带时间查询语句,请教oracle按时间分组查询语句的写法
请教oracle按时间分组查询语句的写法最近由于要做报表,在一张表中有一个字段为date类型,现在想要在一段时间内(比如一年)能够按照时间段分组查询记录总和,比如我要能够查询2007年到2009年间 ...
MySQL数据库中如何使用rand随机查询记录
以下的文章主要介绍的是MySQL使用rand 随机查询记录效率测试,我们大家一直都以为MySQL数据库随机查询的几条数据,就用以下的东东,其实其实际效率是十分低的,以下就是文章的主要内容. 1.SEL ...
学历查询,邮件查询,身份证查询,聊天室查询,日期时间查询,列车飞机航班查询,等各种各类的查询网
EMS全球快递邮件号查询 http://www.ems.com.cn/ems/index.jsp 中国高等教育学历网上证书查询 http://www.chsi.com.cn/xlcx/ 中国黄历查询, ...
MySQL慢查询记录原理和内容解析
点击上方"朱小厮的博客",选择"设为星标" 后台回复"书",获取后台回复"k8s",可领取k8s资料本文并不准备说明 ...
MySQL调优系列：慢查询记录
MySQL慢查询记录 [提前声明] 文章由作者:张耀峰结合自己生产中的使用经验整理,最终形成简单易懂的文章写作不易,转载请注明,谢谢! spark代码案例地址: https://github.co ...
java mysql 时间查询_MYSQL实现查询某个时间段内每一天的数据
作者:2015-02-10 比如查询一周内的访问量,页面显示.如图: 好像Mysql没有提供什么函数可以实现这种功能.目前的做法也只能是根据选择的时间段来生成查询参数.一次查询一天的数据. 我的查询方 ...
java中当前时间查询_SQL 查询当前时间
Mysql: select date_format(now(),'%Y-%m-%d'); Oracle: Oracle中如何获取系统当前时间进行语句的筛选是SQL语句的常见功能获取系统当前时间 da ...
mysql日期与时间查询语句：查询当年、查询本年、查询当月、查询本周
mysql日期与时间查询语句:查询当年.查询本年.查询当月.查询本周 select sum(1) as years, (select sum(1) from `表名` where date_forma ...

kafka按照时间查询记录

kafka按照时间查询记录相关推荐

最新文章

热门文章