1、kafka是什么?
Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据,具有高性能、持久化、多副本备份、横向扩展能力。
2、kafka的工作原理[去耦合]
Kafka采用的是订阅-发布的模式,消费者主动的去kafka集群拉取消息,与producer相同的是,消费者在拉取消息的时候也是找leader去拉取。
3、kafka存在的意义:去耦合、异步、中间件的消息系统。
安装kafka
首先安装 zookeeper
docker search zookeeper
docker pull zookeeper
运行容器:
docker run -d -p 2181:2181--name zookeeper zookeeper
安装kafka
docker search kafka
拉取 这个版本的kafka:
docker pull wurstmeister/kafka
运行容器:
docker run -d --name kafka -p 9092:9092-e KAFKA_BROKER_ID=1-e KAFKA_ZOOKEEPER_CONNECT=120.48.54.67:2181-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://120.48.54.67:9092-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092-v /etc/localtime:/etc/localtime -t wurstmeister/kafka:latest
注册到zookeeper里面。
可视化工具kafka-map
docker pull dushixiang/kafka-map
启动:
docker run -d --name kafka-map -p 8049:8080-e DEFAULT_USERNAME=admin -e DEFAULT_PASSWORD=admin dushixiang/kafka-map:latest
指定一下端口号,登录用户名,密码。
web端访问:
版权归原作者 抹香鲸之海 所有, 如有侵权,请联系我们删除。