不要打印kafka控制台消费者警告

laik7k3q  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(396)

我正在尝试调试Kafka群集上的加密消息。显然,这些消息中充满了不可打印的字符,在控制台上不可用,因此我想将输出保存在如下文件中:

kafka-console-consumer \
    --zookeeper 0.zookeeper.local,1.zookeeper.local \
    --max-messages 1 \
    --topic MYTOPIC > /tmp/message

我无法解密生成的消息,因为输出中包含与密文一起的警告消息,例如:

[2016-02-24 11:52:47,488] WARN Reconnect due to socket error: null (kafka.consumer.SimpleConsumer)

有没有一种方法可以在一个文件中获得一条消息,而不在该文件中嵌入警告?

js4nwp54

js4nwp541#

入站控制台工具有一个特殊的记录器配置文件。请在[kafka\u home]/config/tools-log4j.properties文件中将记录器级别从warn更改为off。文件应如下所示:
工具-log4j.properties

log4j.rootLogger=OFF, stdout 

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

之后,您将只得到控制台中的消息。

0s0u357o

0s0u357o2#

尝试创建新的配置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="INFO"/>
    <logger name="org.apache.kafka.common.metrics" level="INFO"/>
    <root level="debug">
        <appender-ref ref="STDOUT" />
    </root>
</configuration>

相关问题