在进行kafka队列服务的安装之前,确保已安装zookeeper,若未安装,请参照相关教程进行。
Docker提供了一站式的快速部署方案,本实例将采用Docker容器快速部署kafka服务,力求迅速投入生产。
查找kafka镜像,有以下两种方式:官网搜索或命令行搜索。推荐直接在官网搜索,输入关键词'kafka',选择搜索结果中的最新版本,这里选择版本3.6.0。
镜像下载完成,进入镜像列表查看刚下载的kafka镜像。
启动容器并指定参数,命令行如下:
bash
docker run -d -t -p 192.168.54.128:9092:9092 --restart=always \
-e KAFKA_BROKER_ID=0 \
-e ALLOW_PLAINTEXT_LISTENER=yes \
-e KAFKA_CFG_ZOOKEEPER_CONNECT=192.168.54.128:2181 \
-e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://192.168.54.128:9092 \
-e TZ="Asia/Shanghai" --name kafka-0 --privileged=true bitnami/kafka:3.6.0
说明:-d参数用于后台运行,-t参数用于分配一个交互式终端,-p参数用于映射宿主机端口到容器端口,-e参数用于设置环境变量,指定了kafka的运行参数,如设置与zookeeper的连接、服务地址、监听器等。TZ参数用于指定容器的时区。--name用于给容器命名,--privileged赋予容器root权限,确保kafka能正常运行。
验证kafka服务是否启动成功,可执行以下命令进入容器内部:
bash
docker exec -it kafka-0 bash
进入容器后,创建topic、查看topic列表、单个查询topic描述、生产消息、消费消息。
若在容器内遇到问题,如无法执行'ls'命令,可以尝试执行如下命令解决:
bash
chroot /
本文如未解决您的问题请添加抖音号:51dongshi(抖音搜索懂视),直接咨询即可。