Kafka常⽤命令之kafka-console-producer.sh
脚本通过调⽤ 类加载命令⾏参数的⽅式，在控制台⽣产消息的脚本。
⼀、⽆key型消息
 默认情况下，所⽣产的消息是没有 key 的，命令如下：
bin/kafka-console-producer.sh --bootstrap-server localhsot:9092 --topic topicName
 执⾏上述命令后，就会在控制台等待键⼊消息体，直接输⼊消息值(value)即可，每⾏（以换⾏符分隔）表⽰⼀条消息，如下所⽰。
>Hello Kafka!
>你好 kafka!
 正常情况，每次回车表⽰触发“发送”操作，回车后可直接使⽤“Ctrl + c”退出⽣产者控制台，再使⽤ 脚本验证本次的⽣产情况。⼆、有key型消息
console命令大全
 当需要为消息指定 key 时，可使⽤如下命令：
bin/kafka-console-producer.sh --bootstrap-server localhsot:9092 --topic topicName --property parse.key=true
 默认消息键与消息值间使⽤“Tab键”进⾏分隔，切勿使⽤转义字符(\t)，如下所⽰：
>Lei Li    Hello Kafka!
>Meimei Han    你好 kafka!
 键⼊如上信息表⽰所⽣产的消息“Lei Li”为消息键，“Hello Kafka”为消息值。
附表属性列表
 下表列举了当前版本⽀持的所有参数⽤法，敬请参阅。
[--producer-property]优先于此配置
--property String⾃定义消息读取器parse.key=true|false
key.separator=<key.separator> =true|false
--request-required-acks String⽣产者请求的确认⽅式0、1(默认值)、all --request-timeout-ms Integer⽣产者请求的确认超时时间1500(默认值)
--retry-backoff-ms Integer⽣产者重试前，刷新元数据的等待时间阈值100(默认值)
--socket-buffer-size Integer TCP接收缓冲⼤⼩102400(默认值) --timeout Integer消息排队异步等待处理的时间阈值1000(默认值)
--sync同步发送消息
--version 显⽰ Kafka 版本
不配合其他参数时，显⽰为本地Kafka版本
--help打印帮助信息
参数值类型说明有效值

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。