log4j2 kafka appender在所有kafka代理不可用时的故障转移处理?

ecbunoof  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(256)

我用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>

暂无答案!

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

相关问题