你能用log4j写日志到kafkalog4jappender保护的kafka吗

bmvo0sr5  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(251)

我需要将日志写入通过kerberos保护的kafka主题。
我使用的是log4j 1.2.17和kafka 08.2.2。
kafkalog4jappender支持的唯一选项是

var topic: String = null
var brokerList: String = null
var compressionType: String = null
var requiredNumAcks: Int = Int.MaxValue
var syncSend: Boolean = false

这不允许我设置任何jaas选项,例如

com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
keyTab="/keytabs/kafkaclient.keytab"
storeKey=true
useTicketCache=false
serviceName="kafka"
principal="kafkaproducer/_HOST@EXAMPLE.COM";

我是否必须开发一个接受jaas细节的自定义kafkalog4jappender,或者有没有一种方法可以使用kafkalog4jappender向一个安全的kafka主题写入日志?

gc0ot86w

gc0ot86w1#

是的,如果你看看https://github.com/apache/kafka/blob/trunk/log4j-appender/src/main/java/org/apache/kafka/log4jappender/kafkalog4jappender.java 您将注意到可以设置一些sasl属性。你能用这些吗?

相关问题