kafka单节点的安装，部署，使用

一、kafka官网：http://kafka.apache.org/downloads

jdk：https://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

参考书籍：Apache kafka实战

下载安装以下所示：

我下载的是kafka_2.11-2.1.0

而后点击以下进行下载便可：

 下载jdk,根据本身的需求下载所需的jdk版本，64位仍是32位的。我下载的32位的jdk-8u191-linux-i586.tar.gz。

 而后将下载好的jdk-8u191-linux-i586.tar.gz和kafka_2.11-2.1.0.tgz传输到本身的机器上面，找个特定的目录，这样方便本身进行管理。

二、而后将jdk-8u191-linux-i586.tar.gz和kafka_2.11-2.1.0.tgz。解压缩到特定的目录里面，方便管理。

配置jdk的环境变量：

三、启动服务器，配置好jdk和kafka就能够启动了，启动以前要先启动zookeeper服务器，zookeeper是为kafka提升协调服务的工具。kafka已经内置了一个zookeeper服务器以及一些启动脚本。

 

启动好zookeeper之后，而后启动kafka服务器。

 [KafkaServer id=0] started (kafka.server.KafkaServer)说明kafka服务器启动成功，默认的服务端口是9092。

四、建立topic，服务器启动后，咱们须要建立一个主题（topic）用于消息的发送和接受。这一步将建立一个名称为test的topic，该topic只有一个分区（partition）,且该partition也只有一个副本（replica）处理消息。

注意：为了要建立topic，要保证刚才启动的zookeeper和kafka的终端不被关闭。打开一个新的终端。

 而后topic建立成功了，使用命令查看该topic的状态。

 五、发送消息，即生产消息。kafka默认提供了脚本工具能够不断的接受标准输入并将他们发送到kafka的某个topic上面，用户在控制台终端下启动该命令，输入一行文本数据，而后该脚本将改行文本封装成一条kafka消息发送给指定的topic。打开新的终端，执行命令。

 六、消费消息，消费者，kafka提供了一对应的脚本用于消费某些topic下的消息并打印到标准输出。打开新的终端。执行以下命令。

 

待续......