Как настроить ведение журнала для производителей Kafka?

Я использую клиент производителя Kafka, и у меня нет конфигурации log4j в моем проекте.

При запуске программа печатает много журналов отладки Kafka, которые мне действительно не нужны.

Итак, я попытался добавить log4j.properties, чтобы установить уровень журнала в ERROR, как показано ниже, что, похоже, не работает:

log4j.rootLogger=ERROR

Как изменить уровень журнала Kafka?


logging apache-kafka log4j kafka-producer-api
person nikel    schedule 03.03.2016    source источник

Ответы (4)


arrow_upward
13
arrow_downward

Используйте флаг командной строки -Dlog4j.configuration=file:/path/to/log4j.properties при запуске клиента.

Примеры файлов свойств log4j:

Для создателя зеркал и других инструментов, которые приводят к вызову kafka-run-class.sh, вы можете использовать переменную env KAFKA_LOG4J_OPTS (установленную на что-то вроде -Dlog4j.configuration=file:/path/to/log4j.properties), чтобы изменить конфигурацию ведения журнала. См.: https://github.com/apache/kafka/blob/0.10.2/bin/kafka-run-class.sh#L158

Пример моего файла log4j.properties для производителя зеркал, который я использую для тестирования.

# https://github.com/apache/kafka/blob/trunk/config/tools-log4j.properties

log4j.rootLogger=DEBUG, stderr

log4j.appender.stderr=org.apache.log4j.ConsoleAppender
log4j.appender.stderr.layout=org.apache.log4j.PatternLayout
log4j.appender.stderr.layout.ConversionPattern=[%d] %p %m (%c)%n
log4j.appender.stderr.Target=System.err
person turtlemonvh    schedule 26.04.2017

arrow_upward
3
arrow_downward

Попробуйте добавить logging.level.org.apache.kafka: DEBUG в свойства конфигурации вашего клиента. Я использую Springboot, и это формат. Используйте соответствующий формат для вашей клиентской программы.

person sivakadi    schedule 22.11.2016
comment
Cannot set level: WARNING for 'org.apache.kafka' есть идеи? - person forresthopkinsa; 23.01.2018

arrow_upward
0
arrow_downward

Определите уровень ведения журнала, как показано ниже, в файле application.yml или файле свойств.

logging:
  level:
    root: INFO
    org:
      apache:
        kafka: WARN

Определив вышеуказанное, Kafka будет распечатывать только журналы предупреждений.

person Jestino Sam    schedule 19.06.2020

arrow_upward
-1
arrow_downward

Я предположил, что вы говорите о журналах сервера Kafka. Вы можете изменить уровень журнала на ERROR, используя следующую конфигурацию

log4j.logger.kafka=ERROR, kafkaAppender

Надеюсь это поможет!

person avr    schedule 03.03.2016
comment
Я говорю о журналах, которые появляются в моей клиентской программе, а не о сервере kafka как таковом... - person nikel; 03.03.2016