Избыточные консольные сообщения от производителя Кафки

Question

Избыточные консольные сообщения от производителя Кафки

Как вы контролируете уровень регистрации консоли производителя или потребителя Кафки? Я использую API Kafka 0.9 в Scala.

Каждый раз, когда send на KafkaProducer вызывается, консоль выдает вывод, как показано ниже. Может ли это указывать на то, что я не правильно настроил KafkaProducer, а не просто на проблему избыточного протоколирования?

17:52:21.236 [pool-10-thread-7] INFO  o.a.k.c.producer.ProducerConfig - ProducerConfig values: 

compression.type = none

metric.reporters = []

metadata.max.age.ms = 300000

.

.

.

17:52:21.279 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time

17:52:21.280 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records

17:52:21.369 [pool-10-thread-7] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(nodes = [Node(-1, localhost, 9092)], partitions = [])

17:52:21.369 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed:client-id-producer-2

17:52:21.369 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created:client-id-producer-2

17:52:21.370 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received:client-id-producer-2

17:52:21.370 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent:client-id-producer-2

.

.

В файлах properties, которые просматривают сервер Kafka и Zookeeper, есть конфигурации журналов, но я предположил, что они не влияют на клиентов Kafka. Меняющийся некоторые конфигурации регистрации в этих файлах и перезапуск сервера Kafka и Zookeeper, чтобы эти файлы были перезагружены, не решили проблему.

Спасибо

509 3

log4j apache-kafka kafka-producer-api

3 ответов:

Comments

Ничего не найдено.

Atul Soman · Accepted Answer · 2017-06-01 05:17:36

Добавьте это в свой клиентский код.

      Logger.getLogger("org").setLevel(Level.WARNING);
      Logger.getLogger("akka").setLevel(Level.WARNING);       
      Logger.getLogger("kafka").setLevel(Level.WARNING);

iman tung · Accepted Answer · 2017-12-20 12:02:19

Добавить регистратор с именем org.Апача.Кафка в твоем логбэке.xml

<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
    <layout class="ch.qos.logback.classic.PatternLayout">
        <Pattern>
            %d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n
        </Pattern>
    </layout>
</appender>

<logger name="org.apache.kafka" level="warn">
    <appender-ref ref="STDOUT" />
</logger>


<root level="info">
    <appender-ref ref="STDOUT" />
</root>

Peter Becich · Accepted Answer · 2016-02-10 21:43:49

Правильная настройка logback решила мою проблему: http://www.mkyong.com/logging/logback-xml-example/