首先,在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
其中,
docker exec -it kafka bash
kafka-topics --create --zookeeper <zookeeper_host>:<zookeeper_port> --replication-factor <replication_factor> --partitions <partition_num> --topic <topic_name>