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