当前位置: 首页 > article >正文

基于Docker以KRaft模式快速部署Kafka

参考文献 

https://kafka.apache.org/37/documentation.html#uses

https://spring.io/projects/spring-kafka#overview


 

获取Docker镜像

docker pull apache/kafka:3.7.1

创建一个目录来存储Kafka的配置文件

mkdir -p /home/user/kafka_config

启动Kafka容器

docker run -d \
   --name kira-kafka \
   -v /home/user/kafka_config:/opt/kafka/config \
   -p 9092:9092 \
   --user root \
   apache/kafka:3.7.1

cd /var/lib/docker/volumes/kafka_data/_data

创建Kafka的主题

进入Kafka容器

docker exec -u root -it kira-kafka bash

找到kafka-topics.sh:在容器中查找脚本路径

find / -name kafka-topics.sh

创建主题:根据实际的路径,运行命令

/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

查看主题

/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

然后用kafka-King可视化工具进行连接

进入容器内部改成正确的IP(如果内部IP不正确时)

docker exec -u root -it kira-kafka bash

编辑文件

vi /opt/kafka/config/server.properties

删除localhost

esc

:wq保存

删除这个

保留这一行,改成我们的虚拟机本机地址而不是localhost

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://192.168.88.130:9092

退出容器

重启kafka容器

检查本地挂载目录权限保证它可写

ls -ld /home/user/kafka_config

如果目录权限修改不正确,可以使用以下命令修改权限

sudo chown -R 1000:1000 /home/user/kafka_config
sudo chmod -R 755 /home/user/kafka_config

修改容器内权限

docker exec -u root -it kira-kafka bash
chmod -R 777 /opt/kafka/config

重启容器

docker restart kira-kafka

如何验证挂载

进入容器内部

docker exec -it kira-kafka bash

检查挂载目录

ls /opt/kafka/config


http://www.kler.cn/a/524326.html

相关文章:

  • Spring Boot - 数据库集成05 - 集成MongoDB
  • VPR概述、资源
  • 71-《颠茄》
  • Linux基础指令
  • Spring Security(maven项目) 3.0.2.9版本
  • 如何把obsidian的md文档导出成图片,并加上文档属性
  • 使用Avalonia UI实现DataGrid
  • 园区管理系统如何提升企业核心竞争力与资产管理智能化水平
  • 宝塔mysql数据库容量限制_宝塔数据库mysql-bin.000001占用磁盘空间过大
  • LLM 推理
  • 岩田聪游戏思想回顾
  • Mysql Resultset 解析记录
  • 36、【OS】【Nuttx】OSTest分析(2):环境变量测试
  • 【JavaEE】_MVC架构与三层架构
  • matlab学习路线
  • springboot使用rabbitmq
  • 使用CSS实现一个加载的进度条
  • 深度学习可视化指标方法工具
  • Python学习之旅:进阶阶段(五)数据结构-双端队列(collections.deque)
  • 如何将电脑桌面默认的C盘设置到D盘?详细操作步骤!
  • leetcode——排序链表(java)
  • 深入探索SQL中修改表字段属性的技巧与策略
  • 【PyQt5】数据库连接失败: Driver not loaded Driver not loaded
  • 10.2 目录(文件夹)操作
  • 至少是其他数字两倍的最大数(747)
  • Skynet实践之「Lua C 模块集成—优先级队列」