[KAFKA-2571] KafkaLog4jAppender dies while specifying "acks" config

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.9.0.0
• Assignee: Ashish Singh
• Reporter: Ashish Singh
• Reviewer: Jun Rao
• Created: 22/Sep/15 23:16
• Updated: 25/Sep/15 02:16
• Resolved: 25/Sep/15 02:16

Description

KafkaLog4jAppender specifies "acks" config's value as int, however KafkaProducer expects it as a String.

Below is the exception that gets thrown.

Exception in thread "main" org.apache.kafka.common.config.ConfigException: Invalid value -1 for configuration acks: Expected value to be a string, but it was a java.lang.Integer
	at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:219)
	at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:172)
	at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
	at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:55)
	at org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:274)
	at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:179)
	at org.apache.kafka.log4jappender.KafkaLog4jAppender.getKafkaProducer(KafkaLog4jAppender.java:132)
	at org.apache.kafka.log4jappender.KafkaLog4jAppender.activateOptions(KafkaLog4jAppender.java:126)
	at org.apache.log4j.config.PropertySetter.activate(PropertySetter.java:307)
	at org.apache.log4j.config.PropertySetter.setProperties(PropertySetter.java:172)
	at org.apache.log4j.config.PropertySetter.setProperties(PropertySetter.java:104)
	at org.apache.log4j.PropertyConfigurator.parseAppender(PropertyConfigurator.java:842)
	at org.apache.log4j.PropertyConfigurator.parseCategory(PropertyConfigurator.java:768)
	at org.apache.log4j.PropertyConfigurator.configureRootCategory(PropertyConfigurator.java:648)
	at org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:514)
	at org.apache.log4j.PropertyConfigurator.configure(PropertyConfigurator.java:440)
	at org.apache.kafka.clients.tools.VerifiableLog4jAppender.<init>(VerifiableLog4jAppender.java:141)
	at org.apache.kafka.clients.tools.VerifiableLog4jAppender.createFromArgs(VerifiableLog4jAppender.java:124)
	at org.apache.kafka.clients.tools.VerifiableLog4jAppender.main(VerifiableLog4jAppender.java:158)