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);
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.
--
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