共計(jì) 803 個(gè)字符，預(yù)計(jì)需要花費(fèi) 3 分鐘才能閱讀完成。
-
首先，在 Docker Hub 上搜索并下載 Kafka 鏡像，可以使用官方提供的鏡像或者第三方鏡像。
-
使用以下命令運(yùn)行 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 服務(wù)器的主機(jī)名，<zookeeper_host> 和 <zookeeper_port> 為 ZooKeeper 的主機(jī)名和端口號，<topic_name> 為要?jiǎng)?chuàng)建的 Kafka 主題名稱，<partition_num> 為主題的分區(qū)數(shù)，<replication_factor> 為主題的副本因子。
- 等待 Kafka 容器啟動(dòng)完成后，使用以下命令進(jìn)入 Kafka 容器的 bash 終端：
docker exec -it kafka bash
- 在 Kafka 容器中，使用以下命令創(chuàng)建一個(gè)新的 Kafka 主題：
kafka-topics --create --zookeeper <zookeeper_host>:<zookeeper_port> --replication-factor <replication_factor> --partitions <partition_num> --topic <topic_name>
- 現(xiàn)在，Kafka 已經(jīng)安裝并運(yùn)行在 Docker 容器中，可以使用 Kafka 的命令行工具或者客戶端應(yīng)用程序進(jìn)行消息的生產(chǎn)和消費(fèi)。
丸趣 TV 網(wǎng) – 提供最優(yōu)質(zhì)的資源集合！
正文完
