可以自定义 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/
>

回复