package?cn.slimsmart.kafka.demo;

import?java.util.Properties;

import?kafka.javaapi.producer.Producer;
import?kafka.producer.KeyedMessage;
import?kafka.producer.ProducerConfig;

public?class?KafkaProductor?{

	public?static?void?main（String[]?args）?throws?InterruptedException?{
		Properties?properties?=?new?Properties（）;
		properties.put（“zk.connect“?“192.168.36.127:2181192.168.36.91:2181“）;
		properties.put（“metadata.broker.list“?“192.168.36.127:9092192.168.36.91:9092192.168.36.91:9092“）;
		properties.put（“zk.connectiontimeout.ms“?“10000“）;
		properties.put（“serializer.class“?“kafka.serializer.StringEncoder“）;

		ProducerConfig?producerConfig?=?new?ProducerConfig（properties）;
		Producer?producer?=?new?Producer（
				producerConfig）;

		//?構建消息體
		KeyedMessage?keyedMessage?=?new?KeyedMessage（
				“test-topic“?“test-message“）;
		producer.send（keyedMessage）;

		Thread.sleep（1000）;

		producer.close（）;
	}

}

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----

?????文件????????540??2014-11-02?15:44??kafka-demo\pom.xml

?????文件???????1033??2014-11-02?18:12??kafka-demo\src\main\java\cn\slimsmart\kafka\demo\KafkaProductor.java

?????文件???????2202??2014-11-02?18:49??kafka-demo\src\test\java\cn\slimsmart\kafka\demo\KafkaConsumer.java

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\main\java\cn\slimsmart\kafka\demo

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\test\java\cn\slimsmart\kafka\demo

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\main\java\cn\slimsmart\kafka

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\test\java\cn\slimsmart\kafka

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\main\java\cn\slimsmart

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\test\java\cn\slimsmart

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\main\java\cn

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\test\java\cn

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\main\java

?????目錄??????????0??2014-11-02?18:47??kafka-demo\src\main\resources

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\test\java

?????目錄??????????0??2014-11-02?18:47??kafka-demo\src\test\resources

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\main

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src\test

?????目錄??????????0??2014-11-02?18:48??kafka-demo\src

?????目錄??????????0??2014-11-02?18:48??kafka-demo

-----------?---------??----------?-----??----

?????????????????3775????????????????????19