这个可以用配置文件实现,利用kafka
appender将日志打到kafka中,然后自己去消费kafka处理即可,1.11中支持log4j2了,建议使用log4j2

Dream-底限 <[email protected]> 于2020年7月24日周五 上午10:50写道:

> hi、
>
> 我这面想实现一个日志上报的功能,就是flink任务启动后,让flink主动将当前任务日志打到外部存储系统,想问一下flink有对应的接口吗,具体要实现哪一个类哪
>

回复