“Kafka 集群操作”的版本间的差异

来自姬鸿昌的知识库
跳到导航 跳到搜索
（建立内容为“=== 1.搭建 Kafka 集群（三个 broker） === * 创建三个 server.properties文件 <syntaxhighlight lang="properties"> # 0 1 2 broker.id=0 # 9092 9093 9094…”的新页面）
 
第1行： 第1行：
 
=== 1.搭建 Kafka 集群（三个 broker） ===
 
=== 1.搭建 Kafka 集群（三个 broker） ===
  
−
* 创建三个 server.properties文件
+
* 准备3个 server.properties 文件<syntaxhighlight lang="shell-session">
−
<syntaxhighlight lang="properties">
+
[root@localhost ~]# cd /usr/local/kafka/kafka_2.11-2.4.0/config/
−
# 0 1 2
+
[root@localhost config]# cp server.properties server1.properties
 +
[root@localhost config]# cp server.properties server2.properties
 +
</syntaxhighlight>
 +
 
 +
*server.properties<syntaxhighlight lang="apacheconf">
 
broker.id=0
 
broker.id=0
−
# 9092 9093 9094
 
 
listeners=PLAINTEXT://192.168.137.200:9092
 
listeners=PLAINTEXT://192.168.137.200:9092
−
# kafka-logs kafka-logs-1 kafka-logs-2
 
 
log.dirs=/usr/local/kafka/data/kafka-logs
 
log.dirs=/usr/local/kafka/data/kafka-logs
 +
</syntaxhighlight>
 +
*server1.properties<syntaxhighlight lang="apacheconf">
 +
broker.id=1
 +
listeners=PLAINTEXT://192.168.137.200:9093
 +
log.dirs=/usr/local/kafka/data/kafka-logs-1
 +
</syntaxhighlight>
 +
*server2.properties<syntaxhighlight lang="apacheconf">
 +
broker.id=2
 +
listeners=PLAINTEXT://192.168.137.200:9094
 +
log.dirs=/usr/local/kafka/data/kafka-logs-2
 
</syntaxhighlight>
 
</syntaxhighlight>
  
−
* 通过命令来启动三台 broker
+
*启动<syntaxhighlight lang="shell-session">
−
<syntaxhighlight lang="shell-session">
 
 
[root@localhost bin]# ./kafka-server-start.sh -daemon ../config/server.properties
 
[root@localhost bin]# ./kafka-server-start.sh -daemon ../config/server.properties
 
[root@localhost bin]# ./kafka-server-start.sh -daemon ../config/server1.properties
 
[root@localhost bin]# ./kafka-server-start.sh -daemon ../config/server1.properties
第18行： 第29行：
 
</syntaxhighlight>
 
</syntaxhighlight>
  
−
* 校验是否启动成功
+
*搭建完成后通过查看 zk 中的 /brokers/ids 是否启动成功<syntaxhighlight lang="shell-session">
 +
root@4ac6bd5bc9f6:/apache-zookeeper-3.8.0-bin/bin# ./zkCli.sh
 +
[zk: localhost:2181(CONNECTED) 0] ls /brokers/ids
 +
[0, 1, 2]
  
−
进入到 zk 中查看 /brokers/ids 中是否有三个 znode （0,1,2）
+
</syntaxhighlight>

2022年8月24日 (三) 19:50的版本

1.搭建 Kafka 集群（三个 broker）

  • 准备3个 server.properties 文件
    [root@localhost ~]# cd /usr/local/kafka/kafka_2.11-2.4.0/config/
[root@localhost config]# cp server.properties server1.properties 
[root@localhost config]# cp server.properties server2.properties
  • server.properties
    broker.id=0
listeners=PLAINTEXT://192.168.137.200:9092
log.dirs=/usr/local/kafka/data/kafka-logs
  • server1.properties
    broker.id=1
listeners=PLAINTEXT://192.168.137.200:9093
log.dirs=/usr/local/kafka/data/kafka-logs-1
  • server2.properties
    broker.id=2
listeners=PLAINTEXT://192.168.137.200:9094
log.dirs=/usr/local/kafka/data/kafka-logs-2
  • 启动
    [root@localhost bin]# ./kafka-server-start.sh -daemon ../config/server.properties
[root@localhost bin]# ./kafka-server-start.sh -daemon ../config/server1.properties
[root@localhost bin]# ./kafka-server-start.sh -daemon ../config/server2.properties
  • 搭建完成后通过查看 zk 中的 /brokers/ids 是否启动成功
    root@4ac6bd5bc9f6:/apache-zookeeper-3.8.0-bin/bin# ./zkCli.sh
[zk: localhost:2181(CONNECTED) 0] ls /brokers/ids
[0, 1, 2]
取自“https://www.jihongchang.top/index.php?title=Kafka_集群操作&oldid=1084”