在程式碼中使用記錄器

Created: November-22, 2018

將 slf4j 依賴項新增到 pom.xml：

<properties>
    <slf4j.version>1.7.21</slf4j.version>
</properties>

<!-- ... --> 

<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-api</artifactId>
    <version>${slf4j.version}</version>
</dependency>
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-log4j12</artifactId>
    <version>${slf4j.version}</version>
</dependency>

建立一個 logger 物件以在你的類中使用：

private Logger LOGGER = LoggerFactory.getLogger(FlinkApp.class);

在需要序列化的類中，例如 RichMapFunction 的子類，不要忘記將 LOGGER 宣告為 transient：

private transient Logger LOG = LoggerFactory.getLogger(MyRichMapper.class);

在你的程式碼中，像往常一樣使用 LOGGER。使用佔位符（{}）來格式化物件等：

LOGGER.info("my app is starting");
LOGGER.warn("an exception occurred processing {}", record, exception);