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
网友评论