| 常用 | --from-beginning、--max-messages、--partition、--offset |
|---|---|
| 增强 | --property print.key=true / print.timestamp=true |
| 模式 | 不带 --group 为独立随机组;带 --group 会提交位移 |
抽查消息
抽查消息
kafka-console-consumer.sh --bootstrap-server localhost:9092 \
--topic orders --from-beginning --max-messages 5
kafka-console-consumer.sh --bootstrap-server localhost:9092 \
--topic orders --partition 0 --offset earliest --max-messages 3 \
--property print.key=true --property print.timestamp=true带 --group 消费会推进该组位移,可能影响真实业务消费组;抽查优先不带 group。