準備篇

• 需要先搭建好kafka服務器環境，可以參考我上一篇文章Kafka單機環境快速搭建詳細指南

• 創建一個maven工程

開始配置

向pom.xml文件裡面添加如下依賴

<dependencies>

<dependency>

<groupId>org.apache.kafka</groupId>

<artifactId>kafka_2.10</artifactId>

<version>0.8.1</version>

</dependency>

</dependencies>

添加完依賴後在工程目錄上鼠標右鍵——Maven——Update Project...

等待下載完後會依賴如下包

依賴包列表

由於某些原因可能jms、jmxtools、jmxri這三個包會下載不到，一定要看看本地倉庫是否有這三個包，如果沒有的話那麼手動加上去：

• 下載包。我將這三個包放到百度雲盤了供大家下載： http://pan.baidu.com/s/1nvDSJn7

• 將sun文件夾替換掉本地倉庫中的sun文件夾

寫代碼

新建類KafkaProducer 代碼如下：

測試代碼圖片

//一個簡單的生產者發送消息的例子

public class KafkaProducer {

public static void main(String[] args) {

Properties props = new Properties();

props.put("zk.connect", "192.168.153.128:2181");//zookeeper連接地址和端口

props.put("serializer.class", "kafka.serializer.StringEncoder");

props.put("metadata.broker.list", "192.168.153.128:9092");//kafka地址和端口

ProducerConfig config = new ProducerConfig(props);

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

for (int i = 0; i < 10; i++) {

producer.send(new KeyedMessage<String, String>("test", "test" + i)); //發送消息

}

}

}

注意：如果運行時報錯，找不到類的解決辦法

• 首先看包是否確定包含了。

• 再看包版本是否衝突了，版本衝突的話百度“maven包版本衝突”

• 最後刪除掉本地倉庫的所有包重新下載。

如果有不會創建maven工程的同學請留言，後續奉上《maven工程創建完全手冊》

請關注【做你的英雄】，謝謝大家支持。