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

1、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传输到自己的机器上面，找个特定的目录，这样方便自己进行管理。

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

配置jdk的环境变量：

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

启动好zookeeper以后，然后启动kafka服务器。

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

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

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

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

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

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

待续......