You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ashwanth Fernando (JIRA)" <ji...@apache.org> on 2013/04/17 23:19:16 UTC
[jira] [Commented] (KAFKA-224) Shouw throw exception when
serializer.class if not configured for Producer
[ https://issues.apache.org/jira/browse/KAFKA-224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13634451#comment-13634451 ]
Ashwanth Fernando commented on KAFKA-224:
-----------------------------------------
If you remove the serializer.class, the DefaultEncoder - kafka.serializer.DefaultEncoder is used. This is described in http://kafka.apache.org/quickstart.html. Is this an issue?
> 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
> Labels: newbie
>
> 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
For more information on JIRA, see: http://www.atlassian.com/software/jira