使用多个kafka道具在log4j2.properties中配置kafkaappender

xxe27gdn  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(532)

我正在尝试将我的flink应用程序从使用log4 1.x迁移到log4j2,因此尝试在log4j2.properties中配置kafkaappender,其属性如下 retries , compression.type 以及 linger.ms . log4j2似乎用一对属性定义了一个属性 name 以及 value 就像下面的例子。

appender.kafka.property.type=property
appender.kafka.property.name=bootstrap.servers
appender.kafka.property.value=myhost:9092

但要添加更多属性,我是否只需添加 name-value 像下面这样的一对?这感觉就像配置被多次覆盖,而不是创建新属性。在google上找不到太多信息,看起来大多数人都在使用xml而不是属性文件。

appender.kafka.property.name=compression.type
appender.kafka.property.value=gzip

appender.kafka.property.name=linger.ms
appender.kafka.property.value=200

我以前是这样的 appender.kafka.lingerMs=200 在log4j1.x中,但它不再与log4j2一起工作,因为它需要在 appender.kafka.property . 也试过了 appender.kafka.property.linger.ms=200 以及 appender.kafka.property.lingerMs=200 没有运气。
如有任何提示或建议,我们将不胜感激!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题