我知道我可以通過使用log4j kafka appender從使用log4j到Apache Kafka的應用程序發送日誌消息。例如,Log4j appender身份驗證
log4j.appender.KAFKA_HIVE_AUDIT=kafka.producer.KafkaLog4jAppender
log4j.appender.KAFKA_HIVE_AUDIT.BrokerList=sandbox.hortonworks.com:6667
log4j.appender.KAFKA_HIVE_AUDIT.Topic=hive_audit_log
log4j.appender.KAFKA_HIVE_AUDIT.layout=org.apache.log4j.PatternLayout
log4j.appender.KAFKA_HIVE_AUDIT.layout.ConversionPattern=%d{ISO8601} %-5p [%t]: %c{2} (%F:%M(%L)) - %m%n
這說明如下:how to use Kafka 0.8 Log4j appender
我跑卡夫卡0.9具有啓用了Kerberos。有沒有辦法讓log4j appender對Kafka執行身份驗證?某種服務帳戶?
在運行log4j appender之前,有沒有辦法讓運行java程序的機器通過Kerberos通過卡夫卡集羣進行身份驗證?
如果這樣不起作用,有沒有辦法通過計算機爲kerberized Kafka上未經身份驗證的生產者授予寫權限? (並且仍然需要消費者使用Kerberos認證)?
由於該問題專門針對Kafka 0.9,所以這個答案不正確,因此會進行投票。 –
如果它帶給你任何喜悅,那麼歡迎你。但我不確定你的「gittilly correct」答案會得到任何反饋...... –