I have added the configurations suggested, now my log4j appender file looks
as follows
log4j.appender.KAFKA=kafka.producer.KafkaLog4jAppender
log4j.appender.KAFKA.BrokerList=iakafka301p.dev.ch3.s.com:9092,
iakafka302p.dev.ch3.s.com:9092,iakafka303p.dev.ch3.s.com:9092
You can enable producer debug log and verify. In 0.8.2.0, you can set
compressionType
, requiredNumAcks, syncSend producer config properties to log4j.xml. Trunk
build can take additional retries property .
Manikumar
On Thu, Jun 18, 2015 at 1:14 AM, Madhavi Sreerangam
