首先,在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>