
一、安装版本 hadoop-2.7.5 下载地址:Index of /dist/hadoop/core (apache.org) 二、准备工作 1、安装jdk 8及以上版本 2、....
一、rabbitmq安装 第一步、下载好安装包并上传到linux系统 第二步、安装erlang rpm -ivh erlang-21.3-1.el7.x86_64.rpm ....
分布式事务是微服务的重点、难点,也是很多初中级开发工程师进阶的拦路虎,笔者将分布式事务分为三节介绍一下,从理论到实战....
环境配置 spring boot 2.6.3 spring cloud 2021.0.1 spring cloud alibaba 2021.0.1.0 nacos server 2.0.4 dubbo 2.7.15 ....
1、搭建环境时,使用任意的 CentOS 和 VMware 可以,只是可能个别命令不同 2、搭建环境时要仔细,各个步骤成功后再进行下一....
1.在/data目录下创建一个文件 vim wordcount.txt 放入一些词 2.返回hadoop文件夹,在hdfs上创建一个文件夹 bin/hdfs dfs -m....
es7-3.2 restApi 一、elasticSearch7-3.2 restApi1、自动建库的方式2、 手动建库(推荐)3、增删改查4、常用数据类型5、GET6、....
Mysql MySqlSource mySqlSource = MySqlSource.builder() .hostname("localhost") .port(330....
发布确认高级:消息在传递过程中,我们需要确定消息状态信息,开启发布确认高级模式,消息传递结束后会返回传递结果信息,若....
前边讲解的死信交换机可以用来存储那些处理失败的消息,如果消息路由不通,无法进入队列,则死信交换机无法处理到,生产者通....
一、什么是zookeeper zookeeper是一个为分布式框架提供协调服务的Apache项目 二、zookeeper工作机制 是一个基于观察者模式设....
1分箱 分箱:指把待处理的数据按照一定的规则放进“箱子”中,采用某种方法对各个箱子中的数据处理 1)等深分箱法:每个箱子....
Flink的重启策略 Flink的 RestartStrategy 作用是什么? 一句话概括,提升任务健壮性和容错性,保证任务可以实时产出数据。 ....
【报告类型】产业研究 【报告价格】4500起 【出版时间】即时更新(交付时间约3个工作日) 【发布机构】智研瞻产业研究院 【....
Kafka相关问题 Kafka为什么吞吐量大、速度快? 一、顺序读写 众所周知Kafka是将消息记录持久化到本地磁盘中的,一般人会....
这部分主要来说明消费者对协议的处理。 各个消费者都可设置partition.assignment.strategy(分区分配策略),服务端是如何处理....
要说zookeeper节点有多少种类型,直接看创建节点的参数就知道了: org.apache.zookeeper.ZooKeeper#create(java.lang.String....
clickhouse基础概念 一.clickhouse 入门 1.1 介绍 1.2 特点 1.2.1 列式存储 1.2 多样....
作者:黄龙,腾讯 CSIG 高级工程师 Flink Watermark 前言 Flink 水印机制,简而言之,就是在 Flink 使用 Event Time 的情况....