赞
踩
转载:转载并且补充
kafka-console-consumer.sh
脚本是一个简易的消费者控制台。该 shell 脚本的功能通过调用 kafka.tools 包下的 ConsoleConsumer 类,并将提供的命令行参数全部传给该类实现。
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName
表示从 latest 位移位置开始消费该主题的所有分区消息,即仅消费正在写入的消息。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。