You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by zhisheng <zh...@gmail.com> on 2021/08/02 10:05:40 UTC

Re: Flink1.12 用官方默认的log4j2打日志到kafka，如何区分jobmanager和TaskManager的日志？怎么加参数？

可以自定义 KafkaAppender，然后可以从 System.getProperty("log.file")
获取你要的信息维度数据，比如这个可以提取到作业 application id，container_id，是 jobmanager 还是
taskmanager，还可以根据配置只提取想要的级别日志，最后将打的依赖放到 lib 目录下即可

yujianbo <15...@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/
>