【2019-08-07】yqjj spark问题

1.查看topic的情况
kafka-topics.sh --describe --zookeeper 172-16-56-31:24002/kafka --topic TOPIC_TFC_PASS
2.查看数据消费情况

2.获取kafka的情况

获取消息头部位置：
kafka-run-class.sh kafka.tools.GetOffsetShell --topic TOPIC_TFC_PASS --time -1 --broker-list xxx. xxx. xxx. xxx:21005, xxx. xxx. xxx. xxx:21005, xxx. xxx. xxx. xxx:21005
获取消息尾部部位置：
kafka-run-class.sh kafka.tools.GetOffsetShell --topic TOPIC_TFC_PASS --time -2 --broker-list xxx. xxx. xxx. xxx:21005, xxx. xxx. xxx. xxx:21005, xxx. xxx. xxx. xxx:21005