Можете ли вы использовать log4j для записи журналов в защищенный Kafka с KafkaLog4jAppender

Question

У меня есть требование написать журналы в тему Kafka, которая защищена через Kerberos.

Я использую 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"; 

Должен ли я разработать пользовательскую KafkaLog4jAppender, которая принимает JAAS детали или есть способ использовать KafkaLog4jAppender для записи журналов на тему защищенной кафки?

Answer 1

Да, если вы посмотрите на https://github.com/apache/kafka/blob/trunk/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java, вы заметите, что есть некоторые свойства SASL, которые вы можете установить. Можете ли вы использовать их?