共计 803 个字符,预计需要花费 3 分钟才能阅读完成。
-
首先,在 Docker Hub 上搜索并下载 Kafka 镜像,可以使用官方提供的镜像或者第三方镜像。
-
使用以下命令运行 Kafka 容器:
docker run -d --name kafka \
-e KAFKA_ADVERTISED_HOST_NAME=<hostname> \
-e KAFKA_ADVERTISED_PORT=9092 \
-e KAFKA_ZOOKEEPER_CONNECT=<zookeeper_host>:<zookeeper_port>/kafka \
-e KAFKA_CREATE_TOPICS=<topic_name>:<partition_num>:<replication_factor> \
-p 9092:9092 \
-p 2181:2181 \
confluentinc/cp-kafka
其中,为 Kafka 服务器的主机名,<zookeeper_host> 和 <zookeeper_port> 为 ZooKeeper 的主机名和端口号,<topic_name> 为要创建的 Kafka 主题名称,<partition_num> 为主题的分区数,<replication_factor> 为主题的副本因子。
- 等待 Kafka 容器启动完成后,使用以下命令进入 Kafka 容器的 bash 终端:
docker exec -it kafka bash
- 在 Kafka 容器中,使用以下命令创建一个新的 Kafka 主题:
kafka-topics --create --zookeeper <zookeeper_host>:<zookeeper_port> --replication-factor <replication_factor> --partitions <partition_num> --topic <topic_name>
- 现在,Kafka 已经安装并运行在 Docker 容器中,可以使用 Kafka 的命令行工具或者客户端应用程序进行消息的生产和消费。
丸趣 TV 网 – 提供最优质的资源集合!
正文完