Kafka性能篇：为何Kafka这么“快“？
Kafka Broker 的。
zookeeper常用命令
可以是具体IP也可以是IP/bit格式，即IP转换为二进制，匹配前bit位，如192.168.0.0/16匹配192.168..节点的数据是有版本概念的，这个参数用于指定本次更新操作是基于ZNode的哪一个数据版本进行的。语法：setAcl 路径 world:anyone:权限。语法：setAcl
分别使用Redis、MySQL、ZooKeeper构建分布式锁
分别使用Redis、MySQL、ZooKeeper构建分布式锁
根据源码，模拟实现 RabbitMQ - 实现消息持久化，统一硬盘操作(3)
根据源码，自己手敲一个 RabbitMQ？
Hive-安装与配置（1）
Hive在Hadoop生态系统中运行，依赖Hadoop分布式文件系统（HDFS）和YARN资源管理器。元数据存储：Hive使用关系型数据库（如MySQL、Derby等）来存储元数据，包括表的结构、分区信息、数据位置等。Hive服务：Hive提供Hive CLI（命令行界面）和HiveServer2两
RabbitMQ:hello结构
doker-compose up -d 运行。
kafka集成篇
kafka集成篇
Hadoop支持LZO压缩
LZO（Lempel-Ziv-Oberhumer）是一种高效的压缩算法，适用于Hadoop中的数据压缩。Hadoop支持使用LZO算法对数据进行压缩，以减少存储空间占用和数据传输开销。
Zookeeper概述及部署
Zookeeper是一个开源的分布式的，为分布式框架提供协调服务的Apache项目。Zookeeper的工作机制是一个基于观察者模式设计的分布式服务管理框架，它负责存储和管理大家都关心的数据，然后接受观察者的注册，一旦这些数据的状态发生变化，Zookeeper就将负责通知已经在Zookeeper上注
Spark最后一课
如果是Client模式,则Driver就是本机了,Executor 会直接交互本机,远程访问提交,不能停止,同时所有Executor会交互本机,而本机资源不足,会导致系统和网络崩溃.按照等级进行尝试,从高等级到低等级,降级机制.如何避免多次访问通一个节点?9.Driver调用资源,找到空闲的NM,进
hadoop-3.3.3完全分布式集群搭建
hadoop-3.3.3完全分布式集群搭建前言环境准备软件版本集群规划一、配置jdk环境变量1. 解压jdk2. 修改/etc/profile文件二、hadoop集群搭建1. 关闭防火墙2. 修改主机名3. 添加ip映射4. 配置免密登录5. 修改hadoop配置文件1. 解压2. 配置hadoop
kafka--技术文档--基本docker中安装＜单机＞-linux
阿丹小科普：Kafka在0.11.0.0版本之后不再依赖Zookeeper，而是使用基于Raft协议的Kafka自身的仲裁机制来替代Zookeeper。具体来说，Kafka 2.8.0版本是第一个不需要Zookeeper就可以运行Kafka的版本，这被称为Kafka Raft Metadata mo
zookeeper+kafka
1.1 zookeeper的概述ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。ZooKeeper
大数据课程K17——Spark的协同过滤法
用特定的计算方法扫描和指定目标相同的已有用户，根据给定的相似度对用户进行相似度计算，选择最高得分的用户并根据其已有的信息作为推荐结果从而反馈给用户。在已有信息中，用户3已经选择了物品1和物品5，用户2比较偏向于选择物品2和物品4，而用户1选择了物品1、物品4以及物品5。那么完全有理由相信用户1和用户
实战，实现幂等的8种方案！
幂等是一个数学与计算机科学概念。。比如求绝对值的函数，就是幂等的，。计算机科学中，幂等表示一次和多次请求某一个资源应该具有同样的副作用，或者说，多次请求所产生的影响与一次请求执行的影响效果相同。
Canal+Kafka实现Mysql数据同步
译意为水道/管道/沟渠，主要用途是基于 MySQL 数据库增量日志解析，提供增量数据订阅和消费canal可以用来监控数据库数据的变化，从而获得新增数据，或者修改的数据。canal是应阿里巴巴存在杭州和美国的双机房部署，存在跨机房同步的业务需求而提出的。阿里系公司开始逐步的尝试基于数据库的日志解析，获
Kafka监控工具，LinkedIn详解
Kafka Monitor：这是LinkedIn开发的一个监控工具，可以监控Kafka集群的健康和性能，并提供基于Web的用户界面。Kafka Manager：这是一个开源的Kafka集群管理工具，可以监控Kafka集群的健康和性能，并提供可视化的用户界面。Kafka-Web-Console：这是一
借助KafkaTool在海量Kafka数据快速精准定位/查询目标数据
如何在海量的Kafka数据定位/查询精准到秒级的数据？
手搓消息队列【RabbitMQ版】
阻塞队列（Blocking Queue）-> 生产者消费者模型 （是在一个进程内）所谓的消息队列，就是把阻塞队列这样的数据结构，单独提取成了一个程序，进行独立部署~ --------> 生产者消费模型 （进程和进程之间/服务和服务之间）解耦合本来有个分布式系统，A服务器 调用 B服务器（A给B发请求
