前言 本篇文章会从数据的概念和分类，以及数据的处理思路 及如何使用分区去提高性能，使用分区过后的优缺点。我常用来处理大....
一、基础搭建 1.1 使用连接工具连接比赛节点，更改本地源 1.使用本地Windows操作机提供的Xshell或MobaXterm连接比赛平....
1.概述 offset即消费消息的偏移值，记录了kafka每个consumergroup的下一个需要读取消费位置，保障其消息的消费可靠性。 2.旧....
1.软件下载 kafka-manager 工具目前改名为cmak,下载地址为：https://github.com/yahoo/CMAK/releases/tag/3.0.0.5 现在下载....
kafka和zk的基本交互关系 1，kafaka集群的 broker，和 Consumer 都需要连接 Zookeeper。Producer 直接连接 Broker。 2，Pro....
基于hadoop-3.3.0 1 什么是安全模式 安全模式是HDFS所处的一种特殊状态，在这种状态下，文件系统只接受读数据请求，而不接受....
前一节讲述了SpringCloudconfig的相关内容，并且提到了其在动态刷新中的弊端，这个弊端有个解决方法，就是结合SpringCloud B....
Broker：rabbitmq的服务节点 Queue：队列，是RabbitMQ的内部对象，用于存储消息。RabbitMQ中消息只能存储在队列中。生产者投....
zookeeper zookeeper工作机制 Zookeeper从设计模式角度来理解 是一个基于观察者模式设计的分布式服务管理框架，它负责存....
随着互联网的飞速发展，客户的需求呈现多样性，全媒体广告平台的多元化与之刚好契合，获利渠道扩至最大，不同行业的客户根据....
最近小编在过年期间通过一些内部途径获得了这份阿里+腾讯+字节+滴滴+美团 java 面试题及答案（2021 版）的面试题中介，共计....
1. 下载elasticsearch+kibana镜像 docker pull elasticsearch:7.6.2docker pull kibana:7.6.2 2. 配置es挂载目录 mkdir -p /....
一、 ” # ：匹配一个或多个词 * ：匹配不多不少恰好1个词 举例： item.# ：能够匹配 item.insert.abc 或者 item.insert it....
项目背景： 两个Kafka消费者群组，消费同样的主题，一个消费者群组消费数据后，发给mqtt服务，供其他应用接收;另一个消费者....
出现错误： Exception in thread “main” java.lang.IllegalArgumentException: java.net.URISyntaxException: Relative pa....
使用scala编写spark程序，若要使用$""的形式代表列，需要导入语句：import spark.implicits._，其中sparkSparkSession对象。....
十二、 sqoop 将 MySQL 数据导⼊ Hive 1、 将 ambari.users 表导入到 dim_v8sp 数据库在 client-v01 服务器创建 etl ....
开启事务： channel.txSelect(); 提交事务： channel.txCommit(); 回滚事务： channel.txRollback(); 缺点：会影响消息处理....
整合flink-cdc实现实时读postgrasql 什么是wal日志 wal日志即write ahead log预写式日志，简称wal日志。wal日志可以说是Post....
通过大数据分析，科学家认为史前文明也许真的存在 史前文明，是指地球上存在的各种不同时期的文明遗迹。科学家根据考古发现....
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
