Отправка журналов в Кафку с log4j2 - PullRequest
0 голосов
/ 25 сентября 2018

Я пытаюсь использовать log4j2 Kafka appender для отправки логов в тему Kafka.Вот мой файл log4j2.properties:

rootLogger.level=all
rootLogger.type=asyncRoot

logger.main.name=main
logger.main.level=all
logger.main.type=asyncLogger
logger.main.appenderRefs=stdout, kafka
logger.main.appenderRef.stdout.ref=STDOUT
logger.main.appenderRef.kafka.ref=KAFKA

appender.stdout.type=Console
appender.stdout.name=STDOUT
appender.stdout.layout.type=PatternLayout
appender.stdout.layout.pattern=[%d{yyyy-MM-dd HH:mm:ss.SSS}] [%level]\t[%marker] %msg%n

appender.kafka.type=Kafka
appender.kafka.name=KAFKA
appender.kafka.bootstrap.servers=urls:host
appender.kafka.topic=topic_name
appender.kafka.layout.type=PatternLayout
appender.kafka.layout.pattern="some pattern

Когда я запускаю эту конфигурацию, она завершается с исключением:

Исключение в потоке "main" org.apache.logging.log4j.core.config.ConfigurationException: не указан атрибут типа для начальной загрузки компонента в org.apache.logging.log4j.core.config.properties.PropertiesConfigurationBuilder.createComponent (PropertiesConfigurationBuilder.java:334) в org.apache.logorelog..config.properties..config.properties.PropertiesConfigurationBuilder.build (PropertiesConfigurationBuilder.java:158) в org.apache.logging.log4j.core.config.properties.PropertiesConfigurationFactory.getConfiguration (PropertiesConfigurationFactory.java:52) в org.ap.log.ap.config.properties.PropertiesConfigurationFactory.getConfiguration (PropertiesConfigurationFactory.java:35) в org.apache.logging.log4j.core.config.ConfigurationFactory $ Factory.getConfiguration (ConfigurationFactory.java:453) в org.apache.logging.log4j.core.config.ConfigurationFactory $ Factory.getConfiguration (ConfigurationFactory.java:385) в org.apache.logging.log4j.core.config.ConfigurationFactory.getConfiguration (ConfigurationFactory.java:260) в org.apache.logging.log4j.core.LoggerContext.переконфигурируйте (LoggerContext.java:615) на org.apache.logging.log4j.core.LoggerContext.reconfigure (LoggerContext.java:636) на org.apache.logging.log4j.core.LoggerContext.start (LoggerContext.java:231)в org.apache.logging.log4j.core.impl.Log4jContextFactory.getContext (Log4jContextFactory.java:243) в org.apache.logging.log4j.core.impl.Log4jContextFactory.getContext (Log4jContext.act)..logging.log4j.LogManager.getContext (LogManager.java:174) в org.apache.logging.log4j.LogManager.getLogger (LogManager.java:648) в org.apache.logging.log4j.LogManager.getRootLogger (LogManager.java:682)

Что не так?

1 Ответ

0 голосов
/ 19 апреля 2019

Я думаю, вы должны добавить property перед bootstrap.servers

appender.kafka.property.bootstrap.servers=localhost:9092
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...