Пользовательский app Log4j не работает для операторов журнала - PullRequest
Новая
       18

Пользовательский app Log4j не работает для операторов журнала

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

Я пытаюсь транслировать журналы своего приложения на kafka с помощью приложения Log4J.

Я вижу, как журналы запуска выталкиваются на kafka, но журналы моего приложения не публикуются на kafka.

После выполненияВ некоторых исследованиях я заметил, что операторы журнала приложений не вызывают функцию добавления в моем пользовательском приложении.

Вот мой код:

Пользовательское приложение: 

@Plugin(name = "Kafka", category = "Core", elementType = "appender", printObject = true)
public final class KafkaAppender extends AbstractAppender {
    public void append(LogEvent event) {
    System.out.println("##################################### Inside Log Event :"+event.toString());
    try {
        if (producer != null) {
            Future<RecordMetadata> result = producer.send(new ProducerRecord<String, String>(topic, getLayout().toSerializable(event).toString()));
            if(syncsend)
                result.get();
        }
    } catch (final Exception e) {
        LOGGER.error("Unable to write to kafka for appender [{}].",  this.getName(), e);
        throw new AppenderLoggingException("Unable to write to kafka in appender: " + e.getMessage(), e);
    } finally {
    }
}
}

Пом.xml: 

    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-log4j-appender</artifactId>
        <version>1.0.0</version>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-log4j2</artifactId>
        <exclusions>
            <exclusion>
                <groupId>org.apache.logging.log4j</groupId>
                <artifactId>log4j-slf4j-impl</artifactId>
            </exclusion>

                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
        </exclusions>
    </dependency>

Log4j2.xml 

<Configuration status="INFO">
<Appenders>
<Kafka name="KAFKALOGGER" topic="my-test-topic">
    <Property name="bootstrap.servers">server1,server2</Property>
</Kafka>
<Console name="console" target="SYSTEM_OUT">
    <PatternLayout pattern="%d{HH:mm:ss.SSS} %-5p [%-7t] %F:%L - %m%n"/>
</Console>
</Appenders>

<Loggers>
<Root level="INFO">
    <AppenderRef ref="console" />
    <AppenderRef ref="KAFKALOGGER" />
</Root>
<Logger name="net.test.kafka" level="INFO">
    <AppenderRef ref="console" />
    <AppenderRef ref="KAFKALOGGER" />
</Logger>
</Loggers>
</Configuration>

запись оператора в коде: 

@Slf4j
@SpringBootApplication
public class MyTestApplication{
public static void main(String[] args) {

  SpringApplication application = new SpringApplication(MyTestApplication.class);
  log.info("Testing my application from MyTestApplication");
  log.error("Testing my application from MyTestApplication");
  application.run(args);
  log.info("Testing my application from MyTestApplication");
  log.error("Testing my application from MyTestApplication");
}

}
...