首页/数据/数据工程与 ETL 速查/kafka-console-consumer.sh 消费查看消息
Kafka64 条

kafka-console-consumer.sh 消费查看消息

控制台消费者用于抽查消息内容与位点行为:可从头读、指定分区与起始位移、按组消费、打印 key 与时间戳。

常用--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。

易错点

  • --from-beginning 在超大分区上会从头拉取,注意终端与带宽影响,配合 --max-messages 使用
  • 指定了不存在的分区或偏移会直接报错,先 describe 确认分区数

数据来源与参考

  • Apache Kafka 官方文档:Console Consumer 使用说明
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌