
环境配置 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 的情况....
下载 创建一个文件夹存放ZooKeeper,进入该文件夹后使用swet命令下载apache-zookeeper-3.7.0-bin.tar.gz(我的阿里云CentOS7....
下载 进入ZooKeeper主页:https://zookeeper.apache.org/index.html ,点击Download进入下载页面 根据自己的需求下载对应的....
【报告类型】产业研究 【报告价格】4500起 【出版时间】即时更新(交付时间约3个工作日) 【发布机构】智研瞻产业研究院 【....