博客

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）进行分隔