kafka按照时间查询记录

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

姚贤贤

7073人浏览 · 2021-03-09 09:27:02

姚贤贤 · 2021-03-09 09:27:02 发布

本质是重新开始消费，逐条按时间比较
–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}'