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
|
|||
|
|
```
|