[KAFKA-1871] Kafka Producer constructor hungs in case of wrong 'serializer.class' property

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Affects Version/s: 0.8.1.1
• Fix Version/s: 0.8.1.1, 0.8.1.2
• Component/s: clients, producer
• Environment: AWS Linux
• Assignee: Jun Rao
• Reporter: Igor Khomenko
• Created: 16/Jan/15 17:08
• Updated: 02/Feb/15 15:57
• Resolved: 02/Feb/15 15:57

Description

I have next code:

Properties props = new Properties();
props.put("metadata.broker.list", Services.getConfigInstance().getKafkaBrokerList());
props.put("serializer.class", "main.java.com.services.kafka.MessageEntityToJsonSerializer");
props.put("request.required.acks", "0");

ProducerConfig config = new ProducerConfig(props);

if (log.isLoggable(Level.INFO)) {
    log.log(Level.INFO, "Connecting to Kafka...props: " + props);
}

producer = new Producer<String, MessageEntity>(config);

if (log.isLoggable(Level.INFO)) {
    log.log(Level.INFO, "Connected to Kafka");
}

It just hungs on 'new Producer' in case of wrong 'serializer.class' property