0

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 トピックにログを書き込む方法はありますか?

4

1 に答える 1