我用log4j2Kafkaappender将我的所有应用程序日志发送到Kafka,它可以正常工作。但在某种情况下,当我故意关闭代理时,应用程序就会挂断,kafka appender会继续尝试建立连接。
经纪人不在的时候,我怎么能停止写Kafka呢?一有空就继续?
下面是我使用的appender配置。
<Kafka name="KafkaServiceStatInfo" topic="testKafkaLogs">
<PatternLayout pattern="%m"/>
<Property name="bootstrap.servers">localhost:9092</Property>
<Property name="acks">0</Property>
</Kafka>
<Async name="Async">
<AppenderRef ref="KafkaServiceStatInfo"/>
</Async>
暂无答案!
目前还没有任何答案,快来回答吧!