通过日志可以看出,kafka的log清理线程在对log文件改名时发生了错误,log文件被其它线程占用了。
即使在server.properties文件中设置了log.cleaner.enable=false也不管用。
(无法关闭日志清理吗??)
可以手工删除kafka-logs下的文件,不过这样以前的消息就丢了。
另一种方法是,设置log.retention.hours=168000(默认168即7天),使日志不会过期。
通过日志可以看出,kafka的log清理线程在对log文件改名时发生了错误,log文件被其它线程占用了。
即使在server.properties文件中设置了log.cleaner.enable=false也不管用。
(无法关闭日志清理吗??)
可以手工删除kafka-logs下的文件,不过这样以前的消息就丢了。
另一种方法是,设置log.retention.hours=168000(默认168即7天),使日志不会过期。