通過日志可以看出案铺,kafka的log清理線程在對log文件改名時發(fā)生了錯誤,log文件被其它線程占用了梆靖。
即使在server.properties文件中設置了log.cleaner.enable=false也不管用控汉。
(無法關閉日志清理嗎?返吻?)
可以手工刪除kafka-logs下的文件姑子,不過這樣以前的消息就丟了。
另一種方法是测僵,設置log.retention.hours=168000(默認168即7天)街佑,使日志不會過期。
通過日志可以看出案铺,kafka的log清理線程在對log文件改名時發(fā)生了錯誤,log文件被其它線程占用了梆靖。
即使在server.properties文件中設置了log.cleaner.enable=false也不管用控汉。
(無法關閉日志清理嗎?返吻?)
可以手工刪除kafka-logs下的文件姑子,不過這樣以前的消息就丟了。
另一種方法是测僵,設置log.retention.hours=168000(默認168即7天)街佑,使日志不會過期。