kafka使用者向控制台(ecilpse)输出过多的调试语句

ie3xauqp 于 2021-06-08 发布在 Kafka

关注(0)|答案(4)|浏览(507)

我正在运行来自http://www.javaworld.com/article/3060078/big-data/big-data-messaging-with-kafka-part-1.html?page=2，kafkaconsumer根据需要使用from主题，但是每次轮询都会打印（到std out）许多调试日志，这是我不想要的。
我尝试过在中更改所有信息并调试为错误（甚至做了grep来确保） /config/log4j.properties ，特别是设置 log4j.logger.kafka=ERROR ，Kafka出现了，但问题依然存在。我提到了如何为kafka producers？配置日志记录，并在那里采用了解决方案，但是对于消费者来说情况可能有所不同？
调试消息都具有类似的格式：

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

并且以每秒10次左右的速度出现（我试过，把民意测验参数改为1000甚至10000也没用）
非常感谢任何Maven的帮助。提前谢谢！
编辑：不确定这是否重要，但我补充说 BasicConfigurator.configure(); 我的主要方法是，解决以前发生的一些错误，这些错误甚至阻止了使用者启动。

Java apache-kafka Logging kafka-consumer-api Log4j

来源：https://stackoverflow.com/questions/44129303/kafka-consumer-outputs-excessive-debug-statements-to-console-ecilpse

4条答案

按热度按时间

hmae6n7t1#

创建新的配置xml文件
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>

赞(0）回复(0）举报 2021-06-09

ddarikpa2#

只需修改chatty类的日志记录级别（chatty交互）。因为在您的日志中，您可以看到源于 org.apache.kafka.clients.consumer.internals.Fetcher 您可以通过在日志中添加以下行来简单地调整该日志记录器的日志级别 log4j.properties :

log4j.logger.org.apache.kafka.clients.consumer.internals.Fetcher=WARN

... 或任何更宽的标记，因为它们的名称间隔为：


# adjusting logging for entire Kafka

log4j.logger.org.apache.kafka=WARN

希望这有帮助

赞(0）回复(0）举报 2021-06-08

klsxnrf13#

我在另一个与Kafka制作人有关的问题下找到了解决办法，但基本上是同一个问题：https://stackoverflow.com/a/49532152/2380553
所以在我的程序开始时，我只运行以下3行代码：

org.apache.log4j.Logger.getLogger("org").setLevel(Level.WARN);
org.apache.log4j.Logger.getLogger("akka").setLevel(Level.WARN);
org.apache.log4j.Logger.getLogger("kafka").setLevel(Level.WARN);

赞(0）回复(0）举报 2021-06-08

5us2dqdw4#

不确定您是否在谈论kafka控制台使用者命令，如果是，我就是这么做的：

[training@confluent-training-vm ~]$ cd /etc/kafka
[training@confluent-training-vm kafka]$ grep DEBUG *.properties
log4j.properties:# Change to DEBUG or TRACE to enable request logging
log4j.properties:# Access denials are logged at INFO level, change to DEBUG to also 
log allowed accesses
tools-log4j.properties:log4j.rootLogger=DEBUG, stderr

所以，你只需要编辑 /etc/kafka/tools-log4j.properties 归档并删除 DEBUG （或将其替换为exmaple） INFO 以及 WARM 线上的日志级别

tools-log4j.properties:log4j.rootLogger=INFO, WARM, stderr

赞(0）回复(0）举报 2021-06-08

我来回答

kafka使用者向控制台(ecilpse)输出过多的调试语句

4条答案

相关问题

热门标签

最新问答