Sample java client for Apache Kafka Producer

Sample java client for Apache Kafka Producer

package com.apt.server;

import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;
import java.util.Properties;



	
	
	public class KafkaProducer extends Thread
	{
	  private final kafka.javaapi.producer.Producer<Integer, String> producer;
	  private final String topic;
	  private final Properties props = new Properties();

	  public KafkaProducer(String topic)
	  {
	    props.put("serializer.class", "kafka.serializer.StringEncoder");
	    props.put("metadata.broker.list", "localhost:9092");
	    props.put("zk.connect", "localhost:2181");
	    // Use random partitioner. Don't need the key type. Just set it to Integer.
	    // The message is of type String.
	    producer = new kafka.javaapi.producer.Producer<Integer, String>(new ProducerConfig(props));
	    this.topic = topic;
	  }
	  
	  public void run() {
	    int messageNo = 1;
	    while(true)
	    {
	      String messageStr = new String("Message_" + messageNo);
	      KeyedMessage<Integer, String> km = new KeyedMessage<Integer, String>(this.topic, messageStr);
	      try {
			sleep(2000);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
	      producer.send(km);
	      messageNo++;
	    }
	  }

	  public static void main(String[] args) {
		(new KafkaProducer("test")).start();
	  }
	}