我已经整理出了一个成功的appender，它可以毫无问题地向Kafka发送消息，但是我正在阅读（新的）Kafka connect书，并且正在考虑阅读每个Kafka日志消息中的头，并使用 predicate 来确定要应用的转换，但是我找不到appender的log4j2规范中提到的任何地方：
https://logging.apache.org/log4j/2.x/manual/appenders.html#KafkaAppender
有什么可以分享的技术和用例经验吗？
我已经整理出了一个成功的appender，它可以毫无问题地向Kafka发送消息，但是我正在阅读（新的）Kafka connect书，并且正在考虑阅读每个Kafka日志消息中的头，并使用 predicate 来确定要应用的转换，但是我找不到appender的log4j2规范中提到的任何地方：
https://logging.apache.org/log4j/2.x/manual/appenders.html#KafkaAppender
有什么可以分享的技术和用例经验吗？
1条答案
按热度按时间vfwfrxfs1#
您需要编写自己的appender，或者尝试设置一个Kafka Producer Interceptor来修改记录。
您可以在源代码中看到，标题没有添加到记录中。
https://github.com/apache/logging-log4j2/blob/2.x/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java#L156