#!/bin/bash

n_dir=`pwd`
# 每次执行前，先降临时文件清空
>.x.log

# 查看所有组，并挨个查看消费情况，将结果保存到文件
cd /opt/kafka/bin
for i in `./kafka-consumer-groups.sh --bootstrap-server 192.168.1.99:9092 --list`
do
        ./kafka-consumer-groups.sh --bootstrap-server 192.168.1.99:9092 --describe --group $i 2>/dev/null |grep "$i" >> $n_dir/.x.log
done


# 处理文件，将有未消费的行过滤出来
cd $n_dir
IFS=$'\n'
for i in `cat .x.log`
do
        lag=`echo -e $i |awk '{print $6}'`
        if [ $lag -ne '0' ]; then
                echo -e $i
        fi
done