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


冷暖自知一抹茶ck



冷暖自知一抹茶ck
请先登录后发表评论
  • 最新评论
  • 总共0条评论