You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by 罗辉 <lu...@zetyun.com> on 2017/07/05 11:18:31 UTC

org.apache.kafka.common.KafkaException: Failed to construct kafka producer

hi guys:

  I got an exception which i searched searchhadoop.com and the archive as well and got no matches, here it is:

log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to construct kafka producer
 at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:342)
 at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:191)
 at com.zetyum.www.P$.main(P.scala:28)
 at com.zetyum.www.P.main(P.scala)
Caused by: org.apache.kafka.common.KafkaException: org.apache.kafka.common.serialization.StringDeserializer is not an instance of org.apache.kafka.common.serialization.Serializer
 at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:205)
 at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:239)
 ... 3 more


add I tried 0.11 and 0.10 for scala 2.10, both got upper exception. Here is my code:

import org.apache.kafka._
import org.apache.kafka.clients._
import org.apache.kafka.clients.producer._
import org.apache.kafka.clients.consumer._
import org.apache.kafka.common.serialization._
import java.util.Properties

object P {
  def main(args: Array[String]) {
    val brokers = "localhost:9092"
    val topic = "test"
    // Zookeeper connection properties
    val props = new Properties()
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, brokers)
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
      "org.apache.kafka.common.serialization.StringDeserializer")
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
      "org.apache.kafka.common.serialization.StringSerializer")
    val producer = new KafkaProducer[String, String](props)
    while (true) {
      val message = new ProducerRecord[String, String](topic, "1", "1")
      println(message)
      producer.send(message)
    }
    Thread.sleep(1000)
  }
}

thanks for any advices


San

答复: org.apache.kafka.common.KafkaException: Failed to construct kafka producer

Posted by 罗辉 <lu...@zetyun.com>.

thanks you ,got this problem solved with your advice

________________________________
发件人: tao xiao <xi...@gmail.com>
发送时间: 2017年7月5日 20:55:45
收件人: users@kafka.apache.org
主题: Re: org.apache.kafka.common.KafkaException: Failed to construct kafka producer

you need to use org.apache.kafka.common.serialization.StringSerializer as
your ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG

On Wed, 5 Jul 2017 at 19:18 罗 辉 <lu...@zetyun.com> wrote:

> hi guys:
>
>   I got an exception which i searched searchhadoop.com and the archive as
> well and got no matches, here it is:
>
> log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
> more info.
> Exception in thread "main" org.apache.kafka.common.KafkaException: Failed
> to construct kafka producer
>  at
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:342)
>  at
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:191)
>  at com.zetyum.www.P$.main(P.scala:28)
>  at com.zetyum.www.P.main(P.scala)
> Caused by: org.apache.kafka.common.KafkaException:
> org.apache.kafka.common.serialization.StringDeserializer is not an instance
> of org.apache.kafka.common.serialization.Serializer
>  at
> org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:205)
>  at
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:239)
>  ... 3 more
>
>
> add I tried 0.11 and 0.10 for scala 2.10, both got upper exception. Here
> is my code:
>
> import org.apache.kafka._
> import org.apache.kafka.clients._
> import org.apache.kafka.clients.producer._
> import org.apache.kafka.clients.consumer._
> import org.apache.kafka.common.serialization._
> import java.util.Properties
>
> object P {
>   def main(args: Array[String]) {
>     val brokers = "localhost:9092"
>     val topic = "test"
>     // Zookeeper connection properties
>     val props = new Properties()
>     props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, brokers)
>     props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
>       "org.apache.kafka.common.serialization.StringDeserializer")
>     props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
>       "org.apache.kafka.common.serialization.StringSerializer")
>     val producer = new KafkaProducer[String, String](props)
>     while (true) {
>       val message = new ProducerRecord[String, String](topic, "1", "1")
>       println(message)
>       producer.send(message)
>     }
>     Thread.sleep(1000)
>   }
> }
>
> thanks for any advices
>
>
> San
>
>

Re: org.apache.kafka.common.KafkaException: Failed to construct kafka producer

Posted by tao xiao <xi...@gmail.com>.

you need to use org.apache.kafka.common.serialization.StringSerializer as
your ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG

On Wed, 5 Jul 2017 at 19:18 罗 辉 <lu...@zetyun.com> wrote:

> hi guys:
>
>   I got an exception which i searched searchhadoop.com and the archive as
> well and got no matches, here it is:
>
> log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
> more info.
> Exception in thread "main" org.apache.kafka.common.KafkaException: Failed
> to construct kafka producer
>  at
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:342)
>  at
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:191)
>  at com.zetyum.www.P$.main(P.scala:28)
>  at com.zetyum.www.P.main(P.scala)
> Caused by: org.apache.kafka.common.KafkaException:
> org.apache.kafka.common.serialization.StringDeserializer is not an instance
> of org.apache.kafka.common.serialization.Serializer
>  at
> org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:205)
>  at
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:239)
>  ... 3 more
>
>
> add I tried 0.11 and 0.10 for scala 2.10, both got upper exception. Here
> is my code:
>
> import org.apache.kafka._
> import org.apache.kafka.clients._
> import org.apache.kafka.clients.producer._
> import org.apache.kafka.clients.consumer._
> import org.apache.kafka.common.serialization._
> import java.util.Properties
>
> object P {
>   def main(args: Array[String]) {
>     val brokers = "localhost:9092"
>     val topic = "test"
>     // Zookeeper connection properties
>     val props = new Properties()
>     props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, brokers)
>     props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
>       "org.apache.kafka.common.serialization.StringDeserializer")
>     props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
>       "org.apache.kafka.common.serialization.StringSerializer")
>     val producer = new KafkaProducer[String, String](props)
>     while (true) {
>       val message = new ProducerRecord[String, String](topic, "1", "1")
>       println(message)
>       producer.send(message)
>     }
>     Thread.sleep(1000)
>   }
> }
>
> thanks for any advices
>
>
> San
>
>