kafka使用kafka-console-consumer.sh和kafka-console-producer.sh生产消费数据样例

  • Post author:
  • Post category:其他

kafka-console-producer.sh生产无key消息

进入到kafka的bin目录下:执行以下脚本:

./kafka-console-producer.sh --broker-list List<host:port> --topic topicName

在下面的console中输入value后点击enter键即完成数据的生产

kafka-console-producer.sh生产有key消息

进入到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-console-consumer.sh消费消息后不输出key

进入到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-console-consumer.sh消费消息后输出key

进入到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)进行分隔


版权声明:本文为microGP原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。