kafka数据查询过滤的方式
- 详细步骤
1.首先把kafka的数据导出到以log结尾的文件,在kafka安装路径bin目录下执行
./kafka-run-class.sh kafka.tools.DumpLogSegments -print-data-log -files /home/kafka/SA/kafka-0.10.2.1/data/DEVICE_COMMON_CAN-2/00000000000000211636.log>>can.log
2.然后过滤这个文件can.log，查询数据
1).根据以下命令查询到关键字的行号,把这些内容输出到cannum.log文件中，然后根据行号删选内容
cat -n can.log |grep "CG0050161809030007996">> cannum.log
2).根据行号查询内容，然后把这些内容输出到cand.log文件
cat -n can.log |tail -n +35400 >> cand.log
