Integrating apache-kafka client with java application as log appender

Question

Is someone aware of any opensource implementation of Log4J appender which can write log events to Kafka?

Answer 1

There is a KafkaLog4jAppender already included in the Kafka project.

You'll find the api docs to that here: http://people.apache.org/~joestein/kafka-0.7.1-incubating-docs/kafka/producer/KafkaLog4jAppender.html (for 0.7.1)

and the corresponding source code here: https://github.com/apache/kafka/blob/0.7.1/core/src/main/scala/kafka/producer/KafkaLog4jAppender.scala