33 lines
861 B
Markdown
33 lines
861 B
Markdown
- **安装**
|
||
在 $docker-compose.yml$ 文件所在目录下，运行以下命令启动 $Kafka$ 和 $Zookeeper$：
|
||
|
||
```shell
|
||
docker-compose up -d
|
||
```
|
||
|
||
- 验证 $Kafka$ 是否正常运行
|
||
```shell
|
||
docker ps
|
||
```
|
||
输出应显示 $kafka$ 容器正在运行。
|
||
|
||
|
||
- **创建测试主题**
|
||
```shell
|
||
docker exec -it kafka kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
|
||
```
|
||
|
||
- **列出主题**
|
||
```shell
|
||
docker exec -it kafka kafka-topics.sh --list --bootstrap-server localhost:9092
|
||
```
|
||
|
||
- **生产消息**
|
||
```shell
|
||
docker exec -it kafka kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092
|
||
```
|
||
|
||
- **消费消息**
|
||
```shell
|
||
docker exec -it kafka kafka-console-consumer.sh --topic test-topic --bootstrap-server localhost:9092 --from-beginning
|
||
``` |