Kafka根据单点部署启动，无需变更环境变量。Kafka须要将Kafka序列读写能力服务提供给非本地服务器。此实际操作规定在环境变量中更改listeners选择项，将外界服务IP关联到别的服务器以与该机通讯。

listenera=PLAINTEXT://192.168.0.1:9092如果将全部的服务都安装在一个设备上，那麼就无需实现其他的更改。

设备环境规定性能卓越、分布式系统的数据分析能力，而Kafka则以群集的方式产生。根据Kafka的TaskAgent服务，我们可以进行序列数据分析的系统调度。因此当创建Kafka群集时，Zookeeira群集是必不可少的。在具体运用中，检测数据分析无需充分考虑数据分析量的最大值。你能够应用1个单独的节点来创建服务来学习和检测。下列是安装Zookeeira的方法。

第一，Zookeeira安装

WGetymirrors.tuna.tsinghua.eduyapache/zookeeira/zookeira-3.4.14/zookeeira-

3.4.14.tar.gz--no-check-certificate

tar-zxvfzookeeira-3.4.14.tar.gz

Cdzookeeira:3.4.14

2、Zookeeira开始并安装。

sudo./bin/zkserver.sh引导

sudo./bin/zkServer.sh

禁用防火墙的命令包括：

停止服务iptables。

为避免理解中产生偏差，我们给出了完整的Zookeeira配置。

每滴水的毫秒数。

计算时间=2000。

一开始的滴答数。

同时阶段能够采用。

起始约束=10。

能够在#之间传递的刻度数。

发出请求并得到确认。

Synchronize=5。

存放快照的目录。

这里的/tmp不用于存储，而是用于存储别的内容。

给你1个事例。

dataDir=/data0/zookeeira/数据信息

客户机连接的端口。

Client端口=2181。

服务器.1=192.168.0.1:2888:3888

服务器.2=192.168.0.2:2888:3888。

服务器.3=192.168.0.3:2888:3888。

客户机最大连接数。

假如你要接待更多的顾客，我会增加。

#maxClientCnxns=60

1一定要阅读本说明书中的维修部分。

我是管理员指南，随后才打开自动清除。

dataDir中i保留的快照数。

#autopurge.snapRetainunt-3。

按小时计的清除任务间隔。

设为'O'可禁用自动清除功能。

#autopurge.purgeInterval-1

必须根据本地环境的具体情况在环境变量中配置下列项目：

DataDir=/data0/zookeeira/数据信息

在下面的命令中指定Zookeeira服务数据存储的位置：

客户端端口2181。

请按下列命令指定Zookeeira服务端口号：

服务器.1=10.211。

在Kafka中，Kafka有自个的数据信息数据存储器，类似Mysql表和Eysql数据库索引，被称作Topic归类。

如果Kafka服务成功安装，我们最先须要创建1个定阅类型TOPIK，供使用人和制造者应用。KafkaDog在此章的事例中生成数据信息。Catkafka向Kafka序列中载入本地NginxJSON格式的系统日志，随后脚本或Graylog系统日志处理服务损耗序列中的系统日志。

下边是根据zookeeira节点创建的检测TOPIK。

sudobin/kafka-topics.sh--create--zookeeira10.211.*****:2181--replication-factor

--partiys1--TOPIKcandylab_TOPIK。

读取和载入都是应用shell命令。下边的命令代表着将数据信息载入Kafka节点。当脚本进行后，能够立即在终端显示屏上键入字符串数组，无需其他有关命令提示信息。bin/kafka-consollice-ducer.sh--brolist10.211.***.**:9092--TOPIKcandylab-TOPIK制造者有数据信息，消费者有数据信息，我们根据下边的消费者脚本执行该实际操作，观察数据信息制造者插入序列中的数据信息，并且在执行下边的脚本后，制造者载入的数据信息会显示在终端命令行显示屏上。bin/kafka-consolaconsumer.sh--bootstrap-server10.211...**:9092--TOPIKcandylab-TOPIK--from-beginning。