You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2015/09/23 01:27:04 UTC
[jira] [Commented] (KAFKA-2571) KafkaLog4jAppender dies while
specifying "acks" config
[ https://issues.apache.org/jira/browse/KAFKA-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14903655#comment-14903655 ]
Ashish K Singh commented on KAFKA-2571:
---------------------------------------
PR: https://github.com/apache/kafka/pull/231
> KafkaLog4jAppender dies while specifying "acks" config
> ------------------------------------------------------
>
> Key: KAFKA-2571
> URL: https://issues.apache.org/jira/browse/KAFKA-2571
> Project: Kafka
> Issue Type: Bug
> Reporter: Ashish K Singh
> Assignee: Ashish K Singh
>
> KafkaLog4jAppender specifies "acks" config's value as int, however KafkaProducer expects it as a String.
> Below is the exception that gets thrown.
> {code}
> 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)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)