開發環境

• Maven
  Apache Maven 2.5及以上版本，可至Maven官方網站下載。
• JDK
  Java Development Kit 1.8及以上版本，可至Oracle官方網站下載。
  安裝后注意配置JAVA的環境變量。
• IntelliJ IDEA
  獲取并安裝IntelliJ IDEA，可至IntelliJ IDEA官方網站下載。

操作步驟

1. 下載Demo包kafka-java-demo.zip

   下載后解壓，有如下文件：

   表1 KAFKA Demo文件清單

   文件名
   路徑
   說明
   JavaKafkaConfigurer.java
   .\src\main\java\javaDemo
   讀取Kafka配置文件。
   KafkaConsumerDemo.java
   .\src\main\java\javaDemo
   消費消息。
   KafkaMultiConsumerDemo.java
   .\src\main\java\javaDemo
   批量消費消息。
   KafkaProducerDemo.java
   .\src\main\java\javaDemo
   生產消息。
   ? kafka.properties
   .\src\main\resources
   kafka配置參數
   pom.xml
   .\
   maven配置文件，包含Kafka客戶端引用。
   

2. 打開IntelliJ IDEA，導入Demo。Demo是一個Maven構建的Java工程，因此需要配置JDK環境，以及IDEA的Maven插件。

3. 修改Kafka配置信息。
   修改kafka.properties

   修改demo文件中的屬性變量