
使用bitnami镜像:
$ curl -sSL https://raw.githubusercontent.com/bitnami/bitnami-docker-kafka/master/docker-compose.yml > docker-compose.yml $ docker-compose up -d
使用wurstmeister镜像:
启动zookeeper容器:
docker run -d \ --name zookeeper \ --restart=always \ -p 2181:2181 \ wurstmeister/zookeeper
启动kafka容器:
docker run -d --name kafka \ --restart=always \ -p 9092:9092 \ --link zookeeper \ -e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \ -e KAFKA_ADVERTISED_HOST_NAME=192.168.2.200 \ -e KAFKA_ADVERTISED_PORT=9092 \ wurstmeister/kafka
验证kafka,进入容器:
docker exec -it kafka /bin/bash
创建生产者:
kafka-console-producer.sh -broker-list 127.0.0.1:9092 -topic testTopic
创建消费者:
kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 -topic testTopic
保持上面的生产者和消费者在运行状态,在生产者命令行上输入文本回车后,消费者可以看到输出 。
查看主题:
kafka-topics.sh -list --bootstrap-server 127.0.0.1:9092
评论已关闭