在CentOS系统中，Kafka日志清理通常涉及删除旧的日志文件以释放磁盘空间。以下是一些常见的Kafka日志清理方法：

1. 手动删除日志文件

你可以手动删除Kafka日志目录中的旧文件。默认情况下，Kafka的日志文件存储在/var/lib/kafka/logs或/tmp/kafka-logs目录中。

# 进入Kafka日志目录
cd /var/lib/kafka/logs

# 删除旧的日志文件
rm -rf kafka-.*.log.*

2. 使用Kafka自带的日志清理工具

Kafka提供了一个名为kafka-log-dirs.sh的工具，可以用来清理日志目录。

# 进入Kafka bin目录
cd /path/to/kafka/bin

# 清理日志目录
./kafka-log-dirs.sh --clean --delete-all --topic-list "*" --bootstrap-server localhost:9092

3. 配置自动日志清理

你可以在Kafka的配置文件中设置自动日志清理策略。编辑server.properties文件，添加或修改以下配置：

# 日志保留时间（单位：分钟）
log.retention.hours=168

# 日志保留大小（单位：MB）
log.retention.bytes=1073741824

# 日志清理策略（log.dirs）
log.dirs=/var/lib/kafka/logs

4. 使用定时任务自动清理

你可以创建一个定时任务（cron job）来定期清理Kafka日志。

# 编辑crontab文件
crontab -e

# 添加以下行，每天凌晨2点清理日志
0 2 * * * /path/to/kafka/bin/kafka-log-dirs.sh --clean --delete-all --topic-list "*" --bootstrap-server localhost:9092

5. 使用脚本自动化清理

你可以编写一个简单的脚本来自动化日志清理过程。

#!/bin/bash

# 进入Kafka bin目录
cd /path/to/kafka/bin

# 清理日志目录
./kafka-log-dirs.sh --clean --delete-all --topic-list "*" --bootstrap-server localhost:9092

将上述脚本保存为clean_kafka_logs.sh，然后赋予执行权限并运行：

chmod +x clean_kafka_logs.sh
./clean_kafka_logs.sh

注意事项

• 在删除日志文件之前，请确保Kafka集群已经停止或处于安全状态，以避免数据丢失。
• 定期监控磁盘空间使用情况，确保有足够的空间存储新的日志文件。
• 根据实际需求调整日志保留时间和大小，以平衡磁盘空间使用和日志查询需求。

通过以上方法，你可以有效地管理和清理CentOS系统中Kafka的日志文件。