一些工具(如hive)可以借助log4j2把一些信息(如血缘关系)发送到kafka,但是用到的log4j2文件格式为properties,不方便大改为XML、YAML等格式,因此要在现有的properties文件中增加KafkaAppender。但我在官网没有找到
KafkaAppender配置bootstrap.servers、timeout.ms等kafka参数的方法,后来通过各种渠道找到了配置方法,在此记录。如果有朋友在官网找到properties文件的官方说明,烦请告知,非常感谢~
着急的可以直接找到本文重点查看
# 增加KafkaAppender,XXX为其他appenders,这里只是示例 appenders = XXX, KafkaLog appender.KafkaLog.type = Kafka appender.KafkaLog.name = KafkaLog # 输出格式 appender.KafkaLog.layout.type = PatternLayout # 输出模板 appender.KafkaLog.layout.pattern = %m # 输出主题 appender.KafkaLog.topic = test # Kafka参数(本文重点) # properties是个数组,下标按顺序写好 # 要以type、name、value为一组进行配置 # 其中type=Property是固定写法,name写参数名,value写参数值 appender.KafkaLog.properties[0].type=Property appender.KafkaLog.properties[0].name=bootstrap.servers appender.KafkaLog.properties[0].value=localhost:9092 appender.KafkaLog.properties[1].type=Property appender.KafkaLog.properties[1].name=timeout.ms appender.KafkaLog.properties[1].value=30000 appender.KafkaLog.properties[2].type=Property appender.KafkaLog.properties[2].name=XXX appender.KafkaLog.properties[2].value=XXX # ……



