ECS集群中Kafka Rest Proxy日志级别无法修改为ERROR的问题

问题 #

在ECS集群部署Kafka栈后，kafka-rest-proxy持续生成INFO级别日志。已尝试按官方文档调整日志级别，但Cloudwatch仍显示INFO日志。曾参考相关配置模板尝试设置以下环境变量修改日志级别：

ENV KAFKA_REST_LOG4J_LOGGERS="ERROR"
ENV KAFKA_REST_LOG4J_ROOT_LOGLEVEL="ERROR"

但发现声明这些变量后，/etc/kafka-rest/log4j.properties文件内容未改变，当前文件内容如下：

log4j.rootLogger=INFO, stdout, file

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=[%d] %p %m (%c:%L)%n

log4j.appender.file=org.apache.log4j.RollingFileAppender
log4j.appender.file.maxBackupIndex=10
log4j.appender.file.maxFileSize=100MB
log4j.appender.file.File=${kafka-rest.log.dir}/kafka-rest.log
log4j.appender.file.layout=org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern=[%d] %p %m (%c)%n

当前Dockerfile配置如下：

FROM confluentinc/cp-kafka-rest:7.4.0

USER root

COPY ./kafka-rest.properties /home/appuser/kafka-rest.properties
COPY ./password.properties /home/appuser/password.properties
COPY ./rest-jaas.properties /home/appuser/rest-jaas.properties

EXPOSE 80

ENV KAFKAREST_OPTS="-Djava.security.auth.login.config=/home/appuser/rest-jaas.properties"

ENV KAFKA_REST_LOG4J_LOGGERS="ERROR"

ENV KAFKA_REST_LOG4J_ROOT_LOGLEVEL="ERROR"


CMD kafka-rest-start ./kafka-rest.properties

请问这种情况是否正常？该如何解决日志级别无法修改的问题？

解答 #

情况是否正常？ #

不正常。Confluent官方镜像应根据KAFKA_REST_LOG4J_*系列环境变量自动生成/更新log4j.properties配置，但当前配置文件未发生变更，说明环境变量未被正确识别或生效。

解决步骤 #

1. 修正环境变量格式

Confluent镜像的日志环境变量需遵循规范格式：

• KAFKA_REST_LOG4J_ROOT_LOGLEVEL的值需包含appender，正确写法为"ERROR, stdout, file"，而非仅"ERROR"，否则会丢失日志输出目标配置。
• KAFKA_REST_LOG4J_LOGGERS需指定具体包路径，例如"org.apache.kafka=ERROR,io.confluent.rest=ERROR"，直接写"ERROR"无法精准匹配目标日志类。

2. 直接替换自定义log4j.properties

如果环境变量方式失效，可跳过镜像自动生成逻辑，直接替换配置文件：

• 本地创建修改后的log4j.properties，将log4j.rootLogger=INFO, stdout, file改为log4j.rootLogger=ERROR, stdout, file，按需调整其他类的日志级别。
• 在Dockerfile中添加复制命令：

COPY ./log4j.properties /etc/kafka-rest/log4j.properties

3. 通过KAFKAREST_OPTS强制指定日志级别

在JVM启动参数中直接注入日志配置，优先级高于配置文件：

ENV KAFKAREST_OPTS="-Djava.security.auth.login.config=/home/appuser/rest-jaas.properties -Dlog4j.rootLogger=ERROR,stdout,file"

4. 验证环境变量是否生效

启动容器后，进入容器执行env | grep KAFKA_REST_LOG4J，确认环境变量是否正确加载。若未显示，检查Dockerfile中的引号是否为标准双引号（避免转义符错误）。

内容的提问来源于stack exchange，提问作者Pablo Marques