开发环境

• 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文件中的属性变量