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

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

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

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

[root@localhost kafka_2.13-2.6.0]# pwd
/usr/local/src/kafka_2.13-2.6.0


[root@localhost kafka_2.13-2.6.0]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test2

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

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

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

        ./kafka-console-producer.sh --broker-list List<host:port> --topic topicName --property parse.key=true

[root@localhost kafka_2.13-2.6.0]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test2 --property parse.key=true
>kafkaKey	kafkaValue
>

        默认消息key与消息value间使用“Tab键”进行分隔，所以消息key以及value中切勿使用转义字符(\t)

        如所示，kafkaKey为消息key，kafkaValue为消息value，输入之后点击enter键即完成数据的生产消息。

        3、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

[root@localhost kafka_2.13-2.6.0]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic test2

        消费完毕后打印出消费的value值。

        4、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

[root@localhost kafka_2.13-2.6.0]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092  --from-beginning --property print.key=true --topic test2
OpenJDK 64-Bit Server VM warning: If the number of processors is expected to increase from one, then you should configure the number of parallel GC threads appropriately using -XX:ParallelGCThreads=N
null	frist
kafkaKey	kafkaValue

        消费完毕后打印出消费的key以及value值，消息key与消息value间使用“Tab键”（\t）进行分隔。

本文为崔凯原创文章,转载无需和我联系,但请注明来自冷暖自知一抹茶ckhttp://www.cksite.cn

• 上一篇： 你的系统如何支撑高并发？
• 下一篇： Linux kafka服务安装及rdkafka扩展使用