应急命令
应急命令
# 1) 看是哪块盘、哪个主题在涨
df -h /data/kafka
du -sh /data/kafka/* | sort -h | tail -5
kafka-log-dirs.sh --bootstrap-server localhost:9092 --describe | head
# 2) 临时缩短保留期（对已有主题）
kafka-configs.sh --bootstrap-server localhost:9092 \
--entity-type topics --entity-name orders \
--alter --add-config retention.ms=86400000
# 3) 迁移大分区到空闲盘（reassign + log_dirs）
kafka-reassign-partitions.sh --bootstrap-server localhost:9092 \
--reassignment-json-file move-to-disk2.json \
--throttle 50000000 --execute保留时间缩短后删除要等段滚动与检查周期（log.retention.check.interval.ms 默认 5 分钟），不要反复重启 Broker。