我需要将日志写入通过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主题写入日志?
1条答案
按热度按时间gc0ot86w1#
是的,如果你看看https://github.com/apache/kafka/blob/trunk/log4j-appender/src/main/java/org/apache/kafka/log4jappender/kafkalog4jappender.java 您将注意到可以设置一些sasl属性。你能用这些吗?