使用环境:Jdk 1.8
使用场景:生产环境海量数据,用kafka-console-consumer
消费kafka某时间段消息用于分析问题,生产环境海量数据,用kafka-console-consumer.sh只能消费全量,文件巨大,无法grep。
代码来源于博主:BillowX_ ,感谢分享
原贴地址:https://blog.csdn.net/weixin_35852328/article/details/105511784
使用方法见压缩包内;或者直接执行,参数不全时会打印使用方法。
1