[ https://issues.apache.org/jira/browse/KAFKA-224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gwen Shapira resolved KAFKA-224. -------------------------------- Resolution: Not a Problem Closing. Doesn't look like there's an issue here since we have a default. > 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 was sent by Atlassian JIRA (v6.3.4#6332)