incubator-kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stone Gao (Updated) (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (KAFKA-224) Shouw throw exception when serializer.class if not configured for Producer
Date Thu, 08 Dec 2011 03:37:40 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Stone Gao updated KAFKA-224:
----------------------------

    Description: 
  val props = new Properties();
  props.put("zk.connect", "127.0.0.1:2181");
  props.put("producer.type", "async");
  props.put("batch.size", "50")
  props.put("serializer.class", "kafka.serializer.StringEncoder");
  props.put("compression.codec", "1") //gzip
  val config = new ProducerConfig(props);

If remove the serializer.class config : props.put("serializer.class", "kafka.serializer.StringEncoder");
The consumer-shell can no longer get the messages published by producer, so it's like there's
something wrong, but no exception got. 



  was:
  val props = new Properties();
  props.put("zk.connect", "127.0.0.1:2181");
  props.put("producer.type", "async");
  props.put("batch.size", "50")
  props.put("serializer.class", "kafka.serializer.StringEncoder");
  props.put("compression.codec", "1") //gzip
  val config = new ProducerConfig(props);

I remove the serializer.class config : props.put("serializer.class", "kafka.serializer.StringEncoder");
The consumer-shell can no longer get the messages published by producer, so it's like there's
something wrong, but no exception got. 



    
> Shouw throw exception when serializer.class if not configured for Producer
> --------------------------------------------------------------------------
>
>                 Key: KAFKA-224
>                 URL: https://issues.apache.org/jira/browse/KAFKA-224
>             Project: Kafka
>          Issue Type: Bug
>          Components: config, core
>    Affects Versions: 0.7
>            Reporter: Stone Gao
>            Priority: Minor
>
>   val props = new Properties();
>   props.put("zk.connect", "127.0.0.1:2181");
>   props.put("producer.type", "async");
>   props.put("batch.size", "50")
>   props.put("serializer.class", "kafka.serializer.StringEncoder");
>   props.put("compression.codec", "1") //gzip
>   val config = new ProducerConfig(props);
> If remove the serializer.class config : props.put("serializer.class", "kafka.serializer.StringEncoder");
The consumer-shell can no longer get the messages published by producer, so it's like there's
something wrong, but no exception got. 

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Mime
View raw message