您可以使用 log4j 将日志写入带有 KafkaLog4jAppender 的安全 Kafka

Question

我需要将日志写入通过 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 主题？

Answer 1

是的，如果您看一下 https://github.com/apache/kafka/blob/trunk/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java，您会发现有一些 SASL 属性可以设置。你能用那些吗？

您可以使用 log4j 将日志写入带有 KafkaLog4jAppender 的安全 Kafka

Can you use log4j to write logs to secured Kafka with KafkaLog4jAppender

log4j

kerberos

jaas

apache-kafka

kafka-producer-api