| 用途 | 发测试消息、验证序列化与分区 |
|---|---|
| 输入 | 标准输入按行；带 key 需 parse.key=true |
| 传参 | --producer-property 覆盖生产者配置 |
基本用法
基本用法
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic orders
# 输入一行即发送一条：
# {"order_id": "o-1001", "amount": 9.9}
# 带 key（key 与 value 用冒号分隔）
kafka-console-producer.sh --bootstrap-server localhost:9092 \
--topic orders --property parse.key=true --property key.separator=:
# 输入：o-1001:{"amount":9.9}
# 指定 acks 测试
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic orders \
--producer-property acks=all交互模式下 Ctrl+D（EOF）退出；脚本里可用管道批量灌入：printf 或 heredoc 重定向。