gistfile1.java

/*메인함수*/


/*프로듀서 클래스*/
import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;

import java.util.Properties;

public class SampleProducer {

    private static Producer<Integer,String> producer;

    private final Properties props = new Properties();

    public SampleProducer (){

        props.put("metadata.broker.list","182.218.134.111:9092,182.218.134.111:9093,182.218.134.111:9094");
        props.put("serializer.class", "kafka.serializer.StringEncoder");
        producer = new Producer<Integer, String>(new ProducerConfig(props));

    }

    public void send (String messageStr,String topic){
        KeyedMessage<Integer,String> data = new KeyedMessage<Integer, String>(topic,messageStr);
        producer.send(data);

    }

    public void close(){
        producer.close();
    }

}




/* 메인 클래스 */

public class Main {

    public static void main(String[] args) {
	  SampleProducer producer = new SampleProducer();

        producer.send("test 토픽에 날리기","test");

        producer.send("replTest 토픽에 날리기","replTest");

        producer.close();

    }
}