Log4j日志级别异常排查：为何ShardConsumer输出DEBUG级日志？

核心误区澄清 #

你混淆了Log4j日志器的命名空间继承规则和Java类的继承关系：

• Log4j的日志器层级完全基于类的全限定名的包路径，和Java类是否有继承关系毫无关联。
• ShardConsumer的全限定名是org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer，它的日志器父级链是：org.apache.flink.streaming.connectors.kinesis.internals → org.apache.flink.streaming.connectors.kinesis → 上层包 → root。
• 你配置的org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer是类级日志器，它的父级是org.apache.flink.streaming.connectors.kinesis包日志器。

为什么ShardConsumer会输出DEBUG日志？ #

你当前的配置只给FlinkKinesisConsumer类设置了DEBUG级别，但org.apache.flink.streaming.connectors.kinesis包日志器并未显式配置级别，默认会继承root的INFO。理论上ShardConsumer应该只输出INFO及以上日志，但实际出现DEBUG的原因可能是：

1. Flink Kinesis Consumer组件内部代码中，给ShardConsumer的日志器主动设置了DEBUG级别；
2. 存在其他Log4j配置文件（比如Flink默认日志配置）覆盖了你的设置；
3. Log4j的日志器匹配逻辑中，ShardConsumer的日志器意外继承了FlinkKinesisConsumer的级别（这种情况极少，通常是配置写法问题）。

解决方案 #

如果你只想让FlinkKinesisConsumer输出DEBUG，同时让ShardConsumer保持INFO级别，有两种配置方式：

方式1：显式指定ShardConsumer的日志级别

在配置中添加：

logger.shard.consumer.name=org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer
logger.shard.consumer.level=INFO

方式2：先锁定包级别，再单独配置目标类

先给整个kinesis包设置INFO级别，再单独给FlinkKinesisConsumer开启DEBUG：

# 给kinesis包设置默认INFO级别
logger.kinesis.package.name=org.apache.flink.streaming.connectors.kinesis
logger.kinesis.package.level=INFO

# 单独给FlinkKinesisConsumer设置DEBUG
logger.kinesis.consumer.name=org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer
logger.kinesis.consumer.level=DEBUG

这样配置后，internals子包下的ShardConsumer会继承kinesis包的INFO级别，不会输出DEBUG日志。

内容的提问来源于stack exchange，提问作者Vadim Vararu