“1+X中级B卷:Kafka集群”的版本间的差异
（→步骤2） |
（→操作步骤） |
||
| 第28行： | 第28行： | ||
# broker.id=0 | # broker.id=0 | ||
| + | |||
# zookeeper.connect=localhost:2181（这个慢慢找） | # zookeeper.connect=localhost:2181（这个慢慢找） | ||
| 第38行： | 第39行： | ||
listeners=PLAINTEXT://192.168.100.11:9092 | 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 | ||
| + | |||
| + | 这段代码输入上去的结果，复制到我们的答题框即可。 | ||
2020年11月23日 (一) 06:26的版本
题目
继续使用上题的三台虚拟机，使用提供软件包，完成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
找到下面两行，注释掉：
- broker.id=0
- 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
这段代码输入上去的结果，复制到我们的答题框即可。
