apache-kafka - 不要打印kafka-console-consumer警告

Question

我正在尝试将加密的消息调试到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)

有没有一种方法可以在文件中获取一条消息，然后 而不是将警告嵌入该文件中？

Answer 1

对于入站控制台工具，有一个特殊的记录器配置文件。请在[kafka_home]/config/tools-log4j.properties文件中将记录器级别从WARN更改为OFF。该文件应如下所示:

tools-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

之后，您将仅在控制台中收到消息。