查看“1+X中级B卷:Kafka集群”的源代码

==题目==
继续使用上题的三台虚拟机，使用提供软件包，完成Kafka集群的安装与配置，配置完成后，在相应的目录使用 ./kafka-topics.sh --create --zookeeper 你的IP:2181 --replication-factor 1 --partitions 1 --topic test创建topic，将输入命令后的返回结果以文本形式提交到答题框。 

==概念==
什么是kafka ?

https://www.cnblogs.com/qingyunzong/p/9004509.html

==操作步骤==

我们要搭建kafka集群，''' 首先要在zookeeper集群搭建的基础上进行'''，由上一章搭建好zookeeper集群，我们进行下面的kafka集群的搭建。

===步骤1：解压kafka文件包===

首先要把我们的文件包传到root目录下面，使用解


 <nowiki> tar -zxvf kafka_2.11-1.1.1.tgz </nowiki>

===步骤2:配置3个节点文件 ===


在1节点，进入kafka_2.11-1.1.1/config/文件：

 <nowiki> cd kafka_2.11-1.1.1/config/ </nowiki>

 <nowiki> vi server.properties </nowiki>

找到下面两行，注释掉：

 <nowiki> # broker.id=0 </nowiki>


 <nowiki> # zookeeper.connect=localhost:2181（这个慢慢找）</nowiki>

然后在底部添加：（三个节点）

 <nowiki> broker.id=1

zookeeper.connect=192.168.100.11:2181,192.168.100.12:2181,192.168.100.13:2181

listeners=PLAINTEXT://192.168.100.11:9092
</nowiki>

===步骤3:启动服务 ===

 <nowiki> setenforce 0 && systemctl stop firewalld </nowiki>

进入1节点的bin目录（三个节点都输入同样的命令）

 <nowiki> cd ..

cd bin


./kafka-server-start.sh -daemon ../config/server.properties

jps

</nowiki>
===步骤4:测试服务 ===



在1节点，进入bin目录，创建topic命令：

 <nowiki> ./kafka-topics.sh --create --zookeeper 192.168.100.11:2181 --replication-factor 1 --partitions 1 --topic test </nowiki>

这段代码输入上去的结果，复制到我们的答题框即可。