赞
踩
进入到kafka的bin目录下:执行以下脚本:
./kafka-console-producer.sh --broker-list List<host:port> --topic topicName
在下面的console中输入value后点击enter键即完成数据的生产
进入到kafka的bin目录下:执行以下脚本:
./kafka-console-producer.sh --broker-list List<host:port> --topic topicName --property parse.key=true
默认消息key与消息value间使用“Tab键”进行分隔,所以消息key以及value中切勿使用转义字符(\t)
kafkaKey kafkaValue
如上图所示,kafkaKey为消息key,kafkaValue为消息value,输入之后点击enter键即完成数据的生产
进入到kafka的bin目录下:执行以下脚本:(注:0.11之前配置的是--zookeeper,0.11后变成了--bootstrap-server)
./kafka-console-consumer.sh --zookeeper(bootstrap-server) List<host:port> --from-beginning --topic topicName
消费完毕后打印出消费的value值
进入到kafka的bin目录下:执行以下脚本:(注:0.11之前配置的是zookeeper,0.11后变成了broker server)
./kafka-console-consumer.sh --zookeeper(bootstrap-server) List<host:port> --from-beginning --property print.key=true --topic topicName
消费完毕后打印出消费的key以及value值,消息key与消息value间使用“Tab键”(\t)进行分隔
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。