Docker安装RabbitMQ与Kafka

RabbitMq安装(dokcer)

下载镜像

docker pull rabbitmq

创建并启动容器

docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 -v `pwd`/data:/var/lib/rabbitmq --hostname myRabbit -e RABBITMQ_DEFAULT_VHOST=my_vhost  -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin rabbitmq

-d 后台运行容器；
--name 指定容器名；
-p 指定服务运行的端口（5672：应用访问端口；15672：控制台Web端口号）；
-v 映射目录或文件；
--hostname 主机名（RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据，默认为主机名）；
-e 指定环境变量；（RABBITMQ_DEFAULT_VHOST：默认虚拟机名；RABBITMQ_DEFAULT_USER：默认的用户名；RABBITMQ_DEFAULT_PASS：默认用户名的密码）

启动rabbitmq后台管理服务

docker exec -it rabbitmq rabbitmq-plugins enable rabbitmq_management

访问后台页面:

http://127.0.0.1:15672  初始密码: admin  admin

Docker安装Kafka

拉取镜像:
docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka

2、创建容器
docker run -di --name=zk_01 -p 2181:2181  --privileged=true wurstmeister/zookeeper 
docker run -di --network=host --name=kafka_01 -v /etc/localtime:/etc/localtime  --privileged=true wurstmeister/kafka:latest /bin/bash

3、修改kafka的配置文件server.propertiescd /opt/kafka_2.12-2.5.0/config/vi server.propertiesserver.properties配置文件的内容如下所示broker.id=0
# 表示broker的编号，如果集群中有多个broker，则每个broker的编号需要设置的不同listeners=PLAINTEXT://127.0.0.1:9092
# brokder对外提供的服务入口地址log.dirs=/tmp/kafka-logs
# 设置存放消息日志文件的地址zookeeper.connect=127.0.0.1:2181
# Kafka所需Zookeeper集群地址，Zookeeper和Kafka都安装本机

4、启动kafkabin/kafka-server-start.sh config/server.properties

5、创建主题bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --create --topic demo--partitions 2 --replication-factor 1
# 创建主题，表示副本因子，表示每一个分区具有的副本数(包含分区本身)，副本因子数不能超过broker的数量bin/kafka-topics.sh --zookeeper 172.19.0.60:2181 --list 
# 查看所有的主题bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --describe --topic demo
# 查看主题的详细信息bin/kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic demo
# 删除主题bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic demo
# 开启一个消费者bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic demo
# 开启一个生产者修改分区数增加分区数bin/kafka-topics.sh --alter --zookeeper 127.0.0.1:2181 --topic demo--partitions 3修改分区数时，仅能增加分区个数。若是用其减少 partition 个数，则会报如下错误信息：bin/kafka-topics.sh --alter --zookeeper 127.0.0.1:2181 --topic demo--partitions 2