[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.(AbstractConfig.java:48) > at > org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:55) > at > org.apache.kafka.clients.producer.ProducerConfig.(ProducerConfig.java:274) > at > org.apache.kafka.clients.producer.KafkaProducer.(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.(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)
[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=14907405#comment-14907405 ] Ewen Cheslack-Postava commented on KAFKA-2571: -- [~junrao] This one is a trivial patch. LGTM and works with the KAFKA-2531 system test too. > 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.(AbstractConfig.java:48) > at > org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:55) > at > org.apache.kafka.clients.producer.ProducerConfig.(ProducerConfig.java:274) > at > org.apache.kafka.clients.producer.KafkaProducer.(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.(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)
[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=14907416#comment-14907416 ] ASF GitHub Bot commented on KAFKA-2571: --- Github user asfgit closed the pull request at: 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 > Fix For: 0.9.0.0 > > > 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.(AbstractConfig.java:48) > at > org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:55) > at > org.apache.kafka.clients.producer.ProducerConfig.(ProducerConfig.java:274) > at > org.apache.kafka.clients.producer.KafkaProducer.(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.(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)