File tree Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change 9
9
- 当前最新稳定版本(201803):** 1.0.1**
10
10
- 官网 quickstart:< https://kafka.apache.org/quickstart >
11
11
- 核心概念:
12
- - producer:生产者
13
- - consumer:消费者
14
- - broker:可以理解为:存放消息的管道(kafka)
15
- - topic:可以理解为:消息主题、消息标签
12
+ - Producer:生产者(业务系统),负责发布消息到 broker
13
+ - Consumer:消费者(业务系统),向 broker 读取消息的客户端
14
+ - Broker:可以理解为:存放消息的管道(kafka)
15
+ - Topic:可以理解为:消息主题、消息标签(物理上不同 Topic 的消息分开存储,逻辑上一个 Topic 的消息虽然保存于一个或多个 broker 上但用户只需指定消息的 Topic 即可生产或消费数据而不必关心数据存于何处)
16
+ - Partition:Partition 是物理上的概念,每个Topic包含一个或多个Partition.
17
+ - Consumer Group:每个 Consumer 属于一个特定的 Consumer Group(可为每个 Consumer 指定 group name,若不指定 group name 则属于默认的 group)一般一个集群指定一个 group
16
18
- 业界常用的 docker 镜像:
17
19
- [wurstmeister/kafka-docker(不断更新,优先)](https://github.com/wurstmeister/kafka-docker/)
18
20
- 运行的机子不要小于 2G 内存
19
21
- 修改 docker-compose.yml 中参数 KAFKA_ADVERTISED_HOST_NAME,改为你宿主机的 IP 地址
20
22
- 先启动 zookeeper:`docker-compose up -d`
21
- - 添加 kafka 节点:`docker-compose scale kafka=3`
23
+ - 再添加 kafka 节点:`docker-compose scale kafka=3`
22
24
- 停止容器:`docker-compose stop`
23
25
- [spotify/docker-kafka](https://github.com/spotify/docker-kafka)
24
26
You can’t perform that action at this time.
0 commit comments