以下是在Docker下安装Kafka的步骤:
- 确保Docker和Docker已安装 Compose。
- 创建一个叫做“创建”的名字kafka文件夹,然后进入文件夹。
mkdir kafkacd kafka
- 在"kafka在文件夹中创建一个名字docker-compose.yml复制以下文件:
version: '3'services: zookeeper: image: wurstmeister/zookeeper ports: - "2181:2181" kafka: image: wurstmeister/kafka ports: - "9092:9092" environment: KAFKA_ADVERTISED_HOST_NAME: localhost KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
这个Docker Compose文件将启动Zookeper和Kafka服务,并曝光Zookeper端口2181和Kafka端口9092。
- 保存文件并退出编辑器。然后在终端中运行以下命令,启动Kafka集群:
docker-compose up -d
此命令将在后台启动Kafka和Zookeeper服务。
- 等待一段时间,直到所有的Kafka节点都开始。您可以使用以下命令查看正在运行的Docker容器:
docker ps
你应该看到两个容器在运行:一个是zookeper容器,另一个是kafka容器。
- 现在,您可以使用Kafka命令行工具或Kafka客户端应用程序连接到Kafka集群并开始使用它。例如,您可以使用以下命令创建一个名称“test"的主题:
docker-compose exec kafka \ kafka-topics.sh --create --topic test --partitions 1 --replication-factor 1 --if-not-exists --zookeeper zookeeper:2181
这个命令将在Kafka集群上创建一个名字test“主题,只有一个分区和一个备份副本。