可以自定义 KafkaAppender,然后可以从 System.getProperty("log.file") 获取你要的信息维度数据,比如这个可以提取到作业 application id,container_id,是 jobmanager 还是 taskmanager,还可以根据配置只提取想要的级别日志,最后将打的依赖放到 lib 目录下即可
yujianbo <15205029...@163.com> 于2021年6月15日周二 下午7:34写道: > 最新详细配置,可以看看我的博客: > https://blog.csdn.net/weixin_44500374/article/details/117931457 > 如果对你有帮助帮忙点个赞~ > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >