[KAFKA-224] Shouw throw exception when serializer.class if not configured for Producer

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Not A Problem
• Affects Version/s: 0.7
• Component/s: config, core
• Labels: newbie
• Assignee: Unassigned
• Reporter: Stone Gao
• Created: 08/Dec/11 03:33
• Updated: 11/Nov/14 19:24
• Resolved: 11/Nov/14 19:24

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.