
文章目录 一 数据漏消费和重复消费二 自定义Interceptor1 案例需求2 TimeInterceptor类3 CountInterceptor类4 在producer中....
大数据学习阶段 一阶段 python(重点)java(掌握)SQL(掌握)Scala(了解) 二阶段 计算机网络 IP地址的划分和配置(had....
配置jdk1.8 jdk包有问题时初始化namenode会报错: java.lang.InternalError: internal error: SHA-1 not available. 解压jdk....
zookeeper: 为读多写少的场景所设计 并不是存储大规模业务数据 而是用于存储少量的状态和 配置信息,每个节点存储数据不....
1.Hadoop集群搭建及使用 (1).集群规划; (2).虚拟机准备; 1、创建虚拟机(具体步骤不再展示); 2 、配置网络; ping外网....
文章目录 实验示例图注意事项一、什么是elasticsearch?二、什么是Kibana?三、使用docker安装部署elasticsearch四、使用d....
前言 MQ 作为一个消息中间件有着异步提升性能、降低系统耦合度、流量削峰的特点,成为了提升系统应用不可缺少的组件。现在主....
下载地址 Releases · qax-os/ElasticHD · GitHub 下载解压 文件下运行cmd 命令: cd D:EshomeesHD (这里替换掉你下载解....
Windows下安装RocketMQ 1、下载RocketMQ2、启动服务3、测试RocketMQ自带功能4、RocketMQ控制台5、编写对应的Java测试Demo ....
文章目录 系列文章一、concat函数1)横向堆叠与外连接横向堆叠合并df1和df2,采用==外连接==的方式 2) 纵向堆叠与内链接 二....
HDFS的常见Shell操作 直接在命令行中输入hdfs dfs,可以查看dfs后面可以跟的所有参数 注意:这里面的[]表示是可选项,表示....
Mysql 与 Oracle 相比, Mysql 有什么优势?简洁描述 Mysql 中 InnoDB 支持的四种事务隔离级别名称,以及逐级之间的区别?在....
version:8.2 启动相关问题 修改以下配置启动即可 配置文件路径:config/elasticsearch.yml # 关闭 geoip 的自动更新ingest.....
一、实验目的 (1)理解 Hive 作为数据仓库在 Hadoop 体系结构中的角色。 (2)熟练使用常用的 HiveQL。 二、实验平台 操作....
1 介绍 RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回....
KAFKA事件流是什么? Event streaming is the digital equivalent of the human body's central nervous system. It is....
文章目录 零、本讲学习目标一、使用Spark SQL实现词频统计(一)数据源 - words.txt(二)创建Maven项目(三)添加依赖和构....
文章目录 1.硬件选择2.生产者调优2.broker调优3.消费者调优总结 1.硬件选择 服务器个数 内存、磁盘的大小 服务器台数= 2 * ....
一、Zookeeper实现分布式锁思路 1.1.分布式锁应具备哪些条件 分布式锁应该具备以下条件: 在分布式环境下,在一个时间点,最多....
李癩李癩 感谢各位一直以来的支持和鼓励 制作不易 求点赞 ➕ 收藏 ⭐ ⭐ ⭐ ➕ 关注....