在CentOS上查看Kafka的日志,可以按照以下步骤进行:
/tmp/kafka-logs或/var/log/kafka目录下。server.properties)中的log.dirs属性来确定日志的确切位置。tail命令实时查看日志:tail -f /path/to/kafka/logs/server.log
将/path/to/kafka/logs/server.log替换为实际的日志文件路径。
grep结合awk或sed等工具进行筛选。例如:grep "ERROR" /path/to/kafka/logs/server.log | awk '{print $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17, $18, $19, $20, $21, $22, $23, $24, $25, $26, $27, $28, $29, $30, $31, $32, $33, $34, $35, $36, $37, $38, $39, $40, $41, $42, $43, $44, $45, $46, $47, $48, $49, $50, $51, $52, $53, $54, $55, $56, $57, $58, $59, $60, $61, $62, $63, $64, $65, $66, $67, $68, $69, $70, $71, $72, $73, $74, $75, $76, $77, $78, $79, $80, $81, $82, $83, $84, $85, $86, $87, $88, $89, $90, $91, $92, $93, $94, $95, $96, $97, $98, $99, $100' -B 100
这个命令会显示包含"ERROR"的日志行以及它们之前的100行。
Kafka提供了一些内置的脚本来帮助管理和查看日志:
kafka-log-dirs.sh脚本:/path/to/kafka/bin/kafka-log-dirs.sh --describe --bootstrap-server localhost:9092
这个命令会列出所有Kafka broker的日志目录及其状态。
kafka-consumer-groups.sh脚本查看消费者组日志(如果适用):/path/to/kafka/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group your-consumer-group
通过以上方法,你应该能够在CentOS上顺利查看Kafka的日志信息。