ログをKafkaトピックに送信するために、log4j2 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.logging.log4j.core.config.properties.PropertiesConfigurationBuilder.createAppender(PropertiesConfigurationBuilder.java:org.apache.logging.log4j.core.config.properties.PropertiesConfigurationBuilder.processRemainingProperties(PropertiesConfigurationBuilder.java:348)で225)org.apache.logging.log4j.core.config.properties.PropertiesConfigurationBuilder.build(PropertiesConfigurationBuilder.java:158)org.apache.logging.log4j.core.config.properties.PropertiesConfigurationFactory.getConfiguration(PropertiesConfigurationFactory.java: 52)org.apacheで。logging.log4j.core.config.properties.PropertiesConfigurationFactory.getConfiguration(PropertiesConfigurationFactory.java:35)at org.apache.logging.log4j.core.config.ConfigurationFactory $ Factory.getConfiguration(ConfigurationFactory.java:453)at 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.reconfigure(LoggerContext.java:615)at org.apache.logging.logging.loggingj.core.LoggerContext.reconfigure(LoggerContext.java:636)at 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(Log4jContextFactory.java:45)(org.apache.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)
なにが問題ですか?
property
bootstrap.serversの前に追加する必要があると思います
appender.kafka.property.bootstrap.servers=localhost:9092
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加