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

另外这样可以拿到时间,加上print.timestamp=true
kafka-console-consumer --zookeeper 39.135.1.195:2181 --topic cdn-crs-ccs-31 --from-beginning --property print.timestamp=true

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐