[KAFKA-323] Add the ability to use the async producer in the Log4j appender

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.8.0
• Component/s: core
• Labels: appender log4j
• Assignee: Jay Kreps
• Reporter: Jose Quinteiro
• Created: 29/Mar/12 19:51
• Updated: 14/Aug/12 20:36
• Resolved: 14/Aug/12 20:36

Description

I needed the log4j appender to use the async producer, so I added a couple of configuration methods to the log4j appender. I only added methods for the configuration fields that I needed. There are several in in the various ProducerConfigs that still cannot be set in the appender.

Sample use:

KafkaLog4jAppender kafkaAppender = new KafkaLog4jAppender();
kafkaAppender.setZkConnect( "localhost:2181/kafka" );
kafkaAppender.setTopic( "webapp" );
kafkaAppender.setProducerType( "async" );
kafkaAppender.setEnqueueTimeout( Integer.toString( Integer.MIN_VALUE ) );
kafkaAppender.activateOptions();