-
Properties [ "metadata.broker.list", "serializer.class" ] props
-
ProducerConfig (props) producerConfig
-
Producer<K,V> (producerConfig) producer
-
KeyedMessage<K,V> implements scala.Product, scala.Serializable msg
-
producer.send(msg)
-
producer.close()
package chap2;
import kafka.Kafka;
import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;
import kafka.serializer.StringEncoder;
import java.util.Properties;
public class ProducerTest {
public static void main(String[] args) throws Exception {
String topic = "test1";
// 1. Props
Properties props = new Properties();
props.put("metadata.broker.list", "NIE-00:9092");
props.put("serializer.class", "kafka.serializer.StringEncoder");
// 2. producer_conf
ProducerConfig producerConfig = new ProducerConfig(props);
// 3. producer object
Producer<String, String> producer = new Producer<String, String>(producerConfig);
// 4. make msg
KeyedMessage<String, String> msg = null;
for (int i = 0; i < 100; i++) {
msg = new KeyedMessage<String, String>(topic, "测试消息嘻嘻....\t" + i);
Thread.sleep(500);
producer.send(msg);
}
System.out.println("hahaha... will close producer...");
producer.close();
}
}
