1.使用舊API消費
kafka-console-consumer.sh --zookeeper <ZooKeeper集群IP:24002/kafka> --topic <Topic名稱> --from-beginning
2.獲取kafka的情況
獲取消息頭部位置:
kafka-run-class.sh kafka.tools.GetOffsetShell --topic testoffset --time -2 --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 testoffset --time -2 --broker-list xxx. xxx. xxx. xxx:21005, xxx. xxx. xxx. xxx:21005, xxx. xxx. xxx. xxx:21005