查看offset偏移量和lag,看是否正在消费数据
./kafka-consumer-offset-checker.sh --zookeeper <zk-ip:2181> --group <消费组> --topic <主题>
启动一个消费者去消费topic,查看是否有数据到kafka<在自动创建topic中不要使用,执行命令的topic将加入一个随机group>
./kafka-console-consumer.sh --bootstrap-server <kafk-ip:9092&g[......]