我正在尝试将我的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
没有运气。
如有任何提示或建议,我们将不胜感激!
暂无答案!
目前还没有任何答案,快来回答吧!