kafka是一种经常使用的消息队列，可以将数据持久化到消息队列中，可以随时进行消费。同时消息队列的使用可以减少代码的耦合度，因为消息队列接口的开发可以独立于业务系统而存在。kafka以其灵活性、扩展性、可恢复性以及异步通信的特点在开发中得到了广泛的应用，下面小编为大家介绍CentOS 7上安装kafka，在此之前需要Linux服务器上已安装了jdk并且配置了jdk的环境变量。同时需要安装好zookeeper，zookeeper的安装请参考下文。
21CentOS 7上安装zookeeper教程
工具/原料
- CentOS 7
方法/步骤
- 1
首先我们需要下载kafka的压缩包，下载完成后将该压缩包上传到CentOS 7的目录中我们使用tar命令解压，然后使用cd命令进入到解压后的目录中，在该目录中使用mkdir命令创建kafkaLogs用于存放日志，如下图所示。
- 2
接着我们在kafka的解压缩目录下找到config目录，cd config进入到该目录后，找到server.properties文件，该文件便是kafka的配置文件，如下图所示。其他broker.id=0为该机器的唯一标识，若需要安装kafka集群，则其他的机器需要修改这个broker.id。listeners配置的为本机localhost的9092端口，这是kafka的默认端口，localhost可以该为本机的IP地址或者hostname，也可以不使用9092这个默认的端口。
- 3
接下来修改log.dirs为上一步创建的kafkaLogs目录的路径。由于zookeeper是用来管理kafka集群的，我们还需要在配置文件中添加zookeeper的配置，如下图所示。我们的zookeeper和kafka是安装在同一台机器上的，因此zookeeper.connect=localhost:2181，其中2181是zookeeper的默认端口，若安装在不同的机器上则localhost要修改为该机器的IP地址或者hostname，使用hostname是请注意必须要在本机上配置该hostname，我们使用vi /etc/hosts文件即可。
- 4
接下来我们需要将kafka配置到环境变量中，我们使用vi /etc/profile命令打开配置文件，增加kafka的配置即可，然后使用source /etc/profile命令，使得修改生效，如下图所示。
- 5
我们在kafka的bin目录下执行nohup ./kafka-server-start.sh ./config/server.properties 1>/dev/null &命令后台启动kafka，然后使用./kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test来创建topic，并指定toipc的备份数、分区数，如下图所示。
- 6
kafka启动后我们可以使用java的jps命令查看kafka的进程，结果如下图所示。
END
注意事项
- 配置文件中在使用hostname时需要在本机中添加该hostname
- 在windows系统中访问hostname时也需要在hosts文件中添加该hostname
