|
|
| （未显示同一用户的11个中间版本） |
| 第8行： |
第8行： |
| | | | |
| | 一、[[为什么使用消息队列]] | | 一、[[为什么使用消息队列]] |
| | + | |
| | + | |
| | | | |
| | 二、[[消息队列的流派]] | | 二、[[消息队列的流派]] |
| | | | |
| − | 三、[[Kafka的基本知识]]
| |
| | | | |
| − | 四、[[Kafka 中主题和分区的概念]] | + | |
| | + | 三、[[Kafka的基本知识|Kafka 的基本知识]] |
| | + | |
| | + | |
| | + | |
| | + | 四、[[Kafka 中主题和分区的概念|Kafka 中 主题（topic）和分区（partition）的概念]] |
| | + | |
| | + | |
| | + | |
| | + | 五、[[Kafka 集群操作]] |
| | + | |
| | + | |
| | + | |
| | + | 六、[[Kafka 的 Java 客户端-生产者的实现|Kafka 的 Java 客户端-生产者（producer）的实现]] |
| | + | |
| | + | |
| | + | |
| | + | 七、[[Java 客户端消费者的实现细节|Java 客户端消费者（consumer）的实现细节]] |
| | + | |
| | + | https://github.com/jihch/public/tree/main/my-kafka-demo |
| | + | |
| | + | |
| | + | |
| | + | 八、[[Spring Boot 中使用 Kafka]] |
| | + | |
| | + | https://github.com/jihch/public/tree/main/kafka-spring-boot-demo |
| | + | |
| | + | |
| | + | |
| | + | 九、[[Kafka 集群中的 controller、rebalance、HW]] |
| | + | |
| | + | |
| | + | |
| | + | 十、[[Kafka 中的优化问题]] |
| | | | |
| | | | |
| | + | 十一、[[Kafka-Eagle 监控平台]] |
| | | | |
| − | 集群
| + | [[文件:Kafka 组件关系图.png|居中|缩略图|950x950像素|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
| + | [[文件:Kafka 简要架构.png|居中|缩略图|1000x1000像素|Kafka 简要架构]] |
| − | <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 是否启动成功
| |
