“1+X中级B卷:Kafka集群”的版本间的差异

来自CloudWiki
跳转至: 导航搜索
步骤1:解压kafka文件包
第14行: 第14行:
  
  
<nowiki> tar -zxvf kafka_2.11-1.1.1.tgz </nowiki>
+
<nowiki> tar -zxvf kafka_2.11-1.1.1.tgz </nowiki>
  
 
===步骤2:配置3个节点文件 ===
 
===步骤2:配置3个节点文件 ===

2020年11月23日 (一) 06:30的版本

题目

继续使用上题的三台虚拟机,使用提供软件包,完成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

操作步骤

文字+ 输出结果

步骤1:解压kafka文件包

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


 tar -zxvf kafka_2.11-1.1.1.tgz 

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

在1节点,进入kafka_2.11-1.1.1/config/文件:

cd kafka_2.11-1.1.1/config/

vi server.properties

找到下面两行,注释掉:

  1. broker.id=0


  1. zookeeper.connect=localhost:2181(这个慢慢找)

然后在底部添加:(三个节点)

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

步骤3:启动服务

setenforce 0 && systemctl stop firewalld

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

cd ..

cd bin

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

jps


步骤4:测试服务

在1节点,进入bin目录,创建topic命令:

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

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