java - Kafka Consumer输出过多的DEBUG语句到console(eclipse)

Question

我正在运行来自 http://www.javaworld.com/article/3060078/big-data/big-data-messaging-with-kafka-part-1.html?page=2 的一些示例代码，并且 kafkaconsumer 根据需要从主题中消费，但每次轮询都会打印(标准输出)许多调试日志，这是我不想要的。

我尝试在 /config/log4j.properties 中将所有 INFO 和 DEBUG 更改为 ERROR(甚至做了 grep 以确保)，特别是设置 log4j.logger.kafka=ERROR ，kafkaAppender，但问题依旧。我提到了 How to configure logging for Kafka producers? , 并采用了那里的解决方案，但也许消费者的情况有所不同？

DEBUG 消息都具有相似的格式:

[Thread-0] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - Sending fetch for partitions... to broker... (id: 0 rack: null)

并且以每秒 10 次左右的速度出现(将轮询参数更改为 1000 甚至 10000 都无济于事，我试过了)

非常感谢任何专家的帮助。提前致谢!

编辑:不确定它是否重要，但我将 BasicConfigurator.configure(); 添加到我的主要方法中，以解决之前发生的一些其他错误，这些错误甚至阻止了消费者启动。

Answer 1

创建新的配置文件

src/main/resources/logback.xml

<configuration>
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
        </encoder>
    </appender>
    <logger name="org.apache.kafka" level="WARN"/>
    <logger name="org.apache.kafka.common.metrics" level="WARN"/>
    <root level="warn">
        <appender-ref ref="STDOUT" />
    </root>
</configuration>