开发者社区> 问答> 正文

Flink1.12 用官方默认的log4j2打日志到kafka,如何区分jobmanager和Tas

版本:1.12 框架:用默认的log4j2框架 问题:日志打到kafka,如何去区分jobmanager和taskmanger日志?我发现去改layout.pattern,还是没有能找到区分的好办法?

appender.kafka.layout.type=PatternLayout appender.kafka.layout.pattern=%d{yyyy-MM-dd HH:mm:ss,SSS} %-5p %-60c %x - %m%n -- %t -- %F*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-02 11:44:11 870 0
1 条回答
写回答
取消 提交回答
  • 可以在layout中读取系统环境变量作区分

    *来自志愿者整理的FLINK邮件归档

    2021-12-02 11:58:47
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载