如果Kafka清理日志数据不生效,可以尝试以下几种解决方法:
log.cleanup.policy
和log.retention.hours
。kafka-topics.sh
或kafka-log-dirs.sh
来手动触发日志清理操作。log.cleaner.backoff.ms
参数来缩短延迟时间。log.cleaner.threads
参数的值来增加清理线程的数量,以加快日志清理速度。如果上述方法仍然无法解决问题,可以尝试重新启动Kafka节点,或者查看Kafka的日志文件以获取更多的错误信息来排查问题的根本原因。
辰迅云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读: kafka groupid设置能共享吗