Kafka采用的是订阅-发布的模式,消费者主动的去kafka集群拉取消息,与producer相同的是,消费者在拉取消息的时候也是找leader去拉取。
kafka存在的意义:去耦合、异步、中间件的消息系统
首先安装zookeeper
docker search zookeeperdocker pull zookeeperdocker run -d -p 2181:2181 --name zookeeper zookeeper
安装kafkadocker search kafka
docker pull wurstmeister/kafka注册到ZOOKEEPER
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=1 -e KAFKA_ZOOKEEPER_CONNECT=1.15.114.101:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://1.15.114.101:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime -t wurstmeister/kafka:latest
可视化工具
docker pull dushixiang/kafka-mapdocker run -d --name kafka-map -p 8049:8080 -e DEFAULT_USERNAME=admin -e DEFAULT_PASSWORD=admin dushixiang/kafka-map:latest
就可以访问啦