Kafka是用Scala语言编写，运行在JVM上的，为此大家在配置开发环境时，要保证机器具有Java基础开发包JDK和Scala语言库。开发Java或Scala比较好用的IDE有Eclipse、IntelliJ IDEA等，推荐使用IntelliJ IDEA开发Scala应用程序，用Maven工具来进行项目管理，搭建Kafka开发环境需要的软件及下载方式如表15－1所示。

表15－1　搭建Kafka开发环境所需要的软件及下载地址

注意：开发环境在windows 764位操作系统操作中，相应的软件也使用64位的。

有了上面的基本软件环境，大家就可以基于Kafka进行程序开发了，构建基于Kafka的开发项目有如下几种方法：第一，通过Scala IDE直接创建项目；第二，通过项目管理工具Maven来构建项目。这两种方法各有优缺点，用Maven构建项目，只要配置正确的Pom.xml文件、相应的依赖库即可，Maven通过网络自动下载配置中的第三方依赖库。直接用Scala IDE构建项目的话，需要将Kafka依赖的JAR包，手动复制到自己创建的项目中，大家可以选择其中的一种方式来构建基于Kafka的开发项目，本节对这两种方法进行详细阐述。

1.方法一：通过Scala IDE直接创建项目 1）打开Scala IDE集成开发环境。

2）创建Scala项目。

在Eclipse中，依次选择File→New→Scala Project→填写Project name→Finsh命令。

3）导入Kafka第三方依赖包。

在刚创建的项目中，单击鼠标右键，创建一个文件夹（随便命名，这里命名为lib），解压缩Kafka官方网站下载的（kafka　2.11－0.8.2.1.tgz），将安装目录＼kafka　2.11－0.8.2.1＼libs下的所有JAR包，复制到在项目中创建的lib文件夹下。如图15－1所示。

图15－1　将Kafka依赖的开发包复制到项目

4）导入依赖的Kafka JAR包

在Eclipse中，依次执行如下操作：选择刚创建的项目，单击鼠标右键，选择Build Path→Configure Build Path命令，单击Libraries，选择Add JAR，找到刚创建的项目及lib文件夹，选择lib下的全部JAR包，两次单击OK按钮。相关的截图如图15－2和图15－3所示。

图15－2　将Kafka依赖的开发包添加到PATH中(www.daowen.com)

图15－3　将Kafka依赖的开发包添加到PATH中后项目依赖库展现

通过上面几个步骤的操作，就可以在该项目中开发基于Kafka的Producer和Consumer程序了。

2.方法二：通过项目管理工具Maven来构建项目 1）打开Scala IDE集成开发环境。

2）创建Maven项目。

在Eclipse中，执行如下操作：选择File→New→Other命令，选择Maven Project，单击Next按钮，填写Maven project Configure，包括：Artifact Group Id、Artifact Id、Version、Pack⁃aging，Finish按钮。

3）修改刚创建的Maven工程的pom.xml文件。

打开pom.xml文件，填写相应的Kafka依赖包，然后保存（快捷键是Ctrl＋S），该项目自动从网络上下载相应的依赖JAR包（下载速度非常慢，要等一段时间）。

比如，填的是Kafka2.10－0.8.2.1的依赖项，如下所示：

注意：在填写kafka依赖参数时，可以参考官网，也可以参考如下网址：http：／／mvnre⁃pository.com／。

4）用Maven构建Kafka的开发工程，创建完成后，包的组织结构如图15－4所示。修改pom.xml文件之后，相关的依赖包也加入到依赖库中，Kafka　Client　Develop2项目组织结构如图15－5所示。

图15－4　修改pom.xml文件前，Kafka_Client_Develop2项目组织结构

通过上面两种方法对Kafka开发环境进行配置，就可以基于自己的业务逻辑，灵活地开发Kafka的Producer和Consumer应用程序了。