IP属地：山西
1.Shards数量规划 一个index可以被分为多个shards，从而分布到不同的物理机上。Shard的划分结果也会影响索引和查询速度。每个分...
从 ETL 的角度进行分析，一般采集的都是业务库数据，这里使用 MySQL 作为需要采集的数据库，通过 Debezium 把 MySQL Bin...
注：所有操作皆以hive用户运行 1.下载hive版本包apache-hive-3.1.2-bin.tar.gz进行解压 2.修改配置文件 配置...
1.介绍 MavenMaven是Apache的一个项目管理工具，它包含了一个项目对象模型 (Project Object Model)，一组标准...
Kafka Connect 作为service提供了 REST API 服务 管理 Kafka Connector Kafka Connect ...
1、Maven deploy 打包到远程仓库 mvn deploy 用来将项目工程生成的构件分发到远程Maven仓库。例如： Dreposito...
hbase新版本中引入了 BufferedMutator，可以提供更加高效清晰的写操作。 org.apache.hadoop.hbase.cli...
分布式模式下kafka-connect启动运行： 启动命令：bin/connect-distributed.sh conf/connect-di...
写数据流程分析 启动task类方法，HdfsSinkTask.java类中start 初始化DataWriter，DataWriter.java...