java - Kafka Log4j 附加程序中的延迟

Question

这是我的设置，这一切都是在 Eclipse 中完成的

1. 我正在尝试实现 Kafka Log4j 附加程序以将消息泵入 Kafka。

2. 我有一些 java 代码设置来创建日志消息:

   public static void main(String[] args) {
   
   SimpleDateFormat sdf = new SimpleDateFormat();
   
   log.debug("Debug message at "+sdf.format(new Date()));
   
   log.info("Info message at "+sdf.format(new Date()));
   
   log.error("Error Message at "+sdf.format(new Date()));
   
   log.fatal("Fatal Message at "+sdf.format(new Date()));
   
   log.warn("Warn Message at "+sdf.format(new Date()));
   
   log.trace("Trace Message at "+sdf.format(new Date()));
   }
   

3. 这是我的 log4j.properties

   log4j.rootLogger=TRACE, stdout
   log4j.appender.stdout=org.apache.log4j.ConsoleAppender
   log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
   log4j.appender.stdout.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L %% %m%n
   
   log4j.appender.KAFKA=kafka.producer.KafkaLog4jAppender
   log4j.appender.KAFKA.BrokerList=localhost:9092
   log4j.appender.KAFKA.Topic=kfkLogs
   log4j.appender.KAFKA.producer.type=async
   log4j.appender.KAFKA.layout=org.apache.log4j.PatternLayout
   log4j.appender.KAFKA.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L %% - %m%n
   
   log4j.logger.logGen.TestLog4j=TRACE, KAFKA
   

4. 在 Eclipse 的另一个实例中，我运行 Kafka 消费者代码，该代码基本上打印出它收到的任何消息

这是我的问题

当我执行日志生成器时，我并不总是在消费者中看到消息。有时我看到这些消息，有时我看不到。有时我可以重复执行生产者几秒钟，每次我看到消息时，但其他时候，消费者只能获取它们一次，而不是下一分钟左右。然后它再次开始接收。所以我同时推送的消息丢失了。

Kafka 发布消息时是否会出现延迟？

这与我的 Kafka 或 Zookeeper 配置有关吗？

我正在本地主机上执行所有操作

请指教。

Answer 1

log4j.appender.KAFKA.producer.type=sync

已修复。