查看“Kafka”的源代码

https://kafka.apache.org/

https://www.bilibili.com/video/BV1Xy4y1G7zA





一、[[为什么使用消息队列]]

二、[[消息队列的流派]]

三、[[Kafka的基本知识]]

四、[[Kafka 中主题和分区的概念]]



集群

准备3个 server.properties 文件<syntaxhighlight lang="shell-session">
[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
</syntaxhighlight>

*server.properties
<syntaxhighlight lang="apacheconf">
broker.id=0
listeners=PLAINTEXT://192.168.137.200:9092
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 lang="shell-session">
[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
</syntaxhighlight>搭建完成后通过查看 zk 中的 /brokers/ids 是否启动成功