如果你找到正确的JobManager 和TaskManager 的启动命令，如： Java -Dlog.file =...
找到log4j中 类似：${sys:log.file} , ${env:MAX_LOG_FILE_NUMBER:-10} ，一个是系统参数
-Dlog.file ，一个环境变量。
方法有：
1.直接在 运行命令中 加入新参数，再从 log4j 读取相应参数即可，相对直接一些，有可能需要改动源码
2.从日志名入手，你看无论TM 还是 JM ，看日志就区别好了，只要获取
日志名，再正则（在log4j配置中如何正则呢？）获取你想要的日志关键字，取为Kafka的topic name，基本上就可解了
王刚 <wanggang11...@autohome.com.cn> 于2021年6月14日周一 下午3:48写道：
> 用这两个配置 定制不同的启动参数传到log4j配置文件是不是就可以
> env.java.opts.jobmanager
> env.java.opts.taskmanager
>
> 原始邮件
> 发件人: DanielGu<610493...@qq.com>
> 收件人: user-zh<user-zh@flink.apache.org>
> 发送时间: 2021年6月11日(周五) 18:07
> 主题: Re: Flink1.12
> 用官方默认的log4j2打日志到kafka，如何区分jobmanager和TaskManager的日志？怎么加参数？
>
>
> 同求一波配置
> 谢谢大佬们
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>
>
--
Best，
pp
