为 Kafka 追加器配置 log4j.属性，解析属性引导程序服务器时出错

Question

我想添加一个Kafka appender到Cloudera集群中的audit-hdfs日志。

我已经成功地用Kafka appender配置了一个log4j2.xml文件，我需要将这个log4j2.xml转换成一个log4j2.properties文件，以便能够将它与HDFS日志log4j2.properties文件合并。我无法做到这一点，因为当我用log4j2.properties而不是XML启动虚拟进程时，我会收到一个错误。

我尝试以几种不同的方式编写属性文件，但总是导致 bootstrap.servers 属性出现问题

这是我的财产档案

filters = threshold

filter.threshold.type = ThresholdFilter
filter.threshold.level = ALL

appenders = console,kafka

appender.console.type = Console
appender.console.name = console
appender.console.layout.type = PatternLayout
appender.console.layout.pattern = %m%n

appender.kafka.type = Kafka
appender.kafka.name = kafka
appender.kafka.layout.type = PatternLayout
appender.kafka.layout.pattern =%m%n
appender.kafka.property.type = Property
appender.kafka.property.bootstrap.servers = ip:port
appender.kafka.topic = cdh-audit-hdfs

问题出在这一行:appender . Kafka . property . bootstrap . servers = IP:port

我尝试了以下方法，但没有结果：

appender.kafka.property.bootstrap.servers = ip:port

appender.kafka.property.bootstrap\.servers = ip:port

appender.kafka.property.name = "bootstrap.servers"
appender.kafka.property.bootstrap.servers = ip:port

appender.kafka.property.key = "bootstrap.servers"
appender.kafka.property.value = ip:port

等等...

这是我的虚拟过程：

package blabla

import org.apache.logging.log4j.LogManager

object dummy extends App{
  val logger = LogManager.getLogger
  val record = "...c"
  while(true){
    logger.info(record)
    Thread.sleep(5000)
  }
}

我需要如何配置我的log4j2.properties才能定义此属性？

我期望这个过程在我的Kafka主题中写入记录，但是我得到了这样的错误:

Exception in thread "main" org.apache.logging.log4j.core.config.ConfigurationException: No type attribute provided for component bootstrap

Exception in thread "main" org.apache.kafka.common.config.ConfigException: Missing required configuration "bootstrap.servers" which has no default value.

Answer 1

试试这个解决方案，它适用于我：

appender.kafka.property.type=Property
appender.kafka.property.name=bootstrap.servers
appender.kafka.property.value=host:port