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

kafka--技术文档--基本docker中安装<单机>-linux

安装zookeeper

阿丹小科普:

        Kafka在0.11.0.0版本之后不再依赖Zookeeper,而是使用基于Raft协议的Kafka自身的仲裁机制来替代Zookeeper。具体来说,Kafka 2.8.0版本是第一个不需要Zookeeper就可以运行Kafka的版本,这被称为Kafka Raft Metadata mode(Kafka Raft元数据模式)。引入基于Raft协议的KRaft模式使得Kafka可以支持取消对Zookeeper的依赖,用户可以在完全不需要Zookeeper的情况下执行Kafka,这不仅节省了计算资源,而且也使得Kafka性能更好,并可以支持规模更大的集群。

docker run -p 2181:2181 --name zookeeper -v $PWD/conf:/opt/zookeeper/conf -v $PWD/data:/tmp/zookeeper -d mesoscloud/zookeeper:3.4.8

代码解释:

这段代码是用于在 Docker 上运行 Zookeeper 服务的命令。下面是每个选项的解释:

  • -d:在后台运行容器。
  • --name zookeeper-server:给容器命名为 "zookeeper-server"。
  • --network app-tier:将容器连接到名为 "app-tier" 的网络中。
  • -e ALLOW_ANONYMOUS_LOGIN=yes:设置环境变量 ALLOW_ANONYMOUS_LOGIN 为 "yes",允许匿名用户登录。
  • bitnami/zookeeper:latest:使用最新版本的 Bitnami Zookeeper 镜像。

这个命令将在后台运行一个名为 "zookeeper-server" 的容器,并将其连接到名为 "app-tier" 的网络中。容器的环境变量 ALLOW_ANONYMOUS_LOGIN 被设置为 "yes",以允许匿名用户登录。最后,使用最新版本的 Bitnami Zookeeper 镜像来启动容器。

 查看zookeeper容器日志(可省略)

docker logs -f zookeeper

 安装kafka

docker run  -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=ip:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://ip:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -d wurstmeister/kafka:2.11-2.0.0

安装并运行Kafka,
–name:容器名称
-p:设置映射端口(默认9092 )
-d:后台启动
ALLOW_PLAINTEXT_LISTENER任何人可以访问
KAFKA_CFG_ZOOKEEPER_CONNECT链接的zookeeper
ALLOW_PLAINTEXT_LISTENER任何人可以访问
KAFKA_CFG_ZOOKEEPER_CONNECT链接的zookeeper
KAFKA_CFG_ADVERTISED_LISTENERS当前主机IP或地址(重点:如果是服务器部署则配服务器IP或域名否则客户端监听消息会报地址错误)


查看kafka容器日志(可省略)

docker logs -f kafka

kafka-map图形化管理工具(好用)

图形化管理工具
访问地址:http://服务器IP:9001/
DEFAULT_USERNAME:默认账号admin
DEFAULT_PASSWORD:默认密码admin

docker run -d --name kafka-map \-p 8080:8080 \-v /opt/kafka-map/data:/usr/local/kafka-map/data \-e DEFAULT_USERNAME=admin \-e DEFAULT_PASSWORD=admin \--restart always dushixiang/kafka-map:latest

 

http://www.lryc.cn/news/135667.html

相关文章:

  • 回归预测 | MATLAB实现WOA-RF鲸鱼优化算法优化随机森林算法多输入单输出回归预测(多指标,多图)
  • Linux系统安全——NAT(SNAT、DNAT)
  • uniapp项目添加人脸识别功能,可用作登录,付款,流程审批前的安全校验
  • SpringBoot面试题
  • Git相关命令
  • 《HeadFirst设计模式(第二版)》第八章代码——模板方法模式
  • RESTful API,以及如何使用它构建 web 应用程序
  • Git+Gitee使用分享
  • 【3D激光SLAM】LOAM源代码解析--transformMaintenance.cpp
  • DiscuzQ 二开教程(7)——二次开发版本部署文档
  • u盘数据丢失但占内存如何恢复?不要着急,这里有拯救方案
  • springboot日志文件名称为什么叫logback-spring.xml
  • Mysql 开窗函数(窗口函数)
  • 计算机视觉之图像特征提取
  • 【面试经典150题】移除元素·JavaScript版
  • Cesium 相机的三种放置方式
  • 看了我这篇帖子,你还会觉得制作电子杂志很难吗?
  • SRE 与开发的自动化协同 -- 生产环境出现 bug 自动生成异常追踪
  • 【简单认识Docker基本管理】
  • 设备管理系统是什么?的修设备管理系统有什么功能?
  • Docker安装并配置Pushgateway
  • 汽车OTA活动高质量发展的“常”与“新”
  • C++信息学奥赛1121:计算矩阵边缘元素之和
  • Android Selector 的使用
  • k8s集群中service的域名解析、pod的域名解析
  • Shell 编程快速入门 之 数学计算和函数基础
  • 学习php中如何获取pdf文件中的文本内容
  • 分布式数据库架构:高可用、高性能的数据存储
  • Python工具箱系列(四十)
  • 【Hibench 】完成 HDP-Spark 性能测试