kafka-topic.sh
kafka-topic.sh先看具体脚本信息
123#!/bin/bash# 中间注释已删除exec $(dirname $0)/kafka-run-class.sh kafka.admin.TopicCommand "$@"
脚本命令很简单，通过 kafka-run-class.sh 启动 ka
...
源码环境搭建
环境准备
JDK 1.8
1234C:\Users\Administrator>java -versionjava version "1.8.0_201"Java(TM) SE Runtime Environment (build 1.8.0_201-b09)Java H
...
atlas后续计划
初步计划1、安装或升级HBase：由于集群中的版本有点低，Atlas 2.0 需要 HBase2.0。
2、安装Atlas：需要集成集群的，还需要Solr7.5集群。初步不考虑HA，HA需要更多机器。由于HDP已经安装了 Atlas 0.5，需要卸载掉。不然会对新的 Atlas产生不必要的影响。
第
...
atlas-Hook
Atlas HookAtlas 提供了关于 Hive、HBase、Kafka、Sqoop、Storm 和 Falcon 等组件的 Hook。
在安装包中已经含有 hook 和 hook-bin，不需要像官网所说，需要解压相关hook包，然后拷贝到安装目录。
Hive Hook分批量导入 和 hook
...
atlas安装部署
安装部署单机版内嵌HBase和Solr安装参照 https://blog.csdn.net/czq850114000/article/details/89518215
Atlas 编译参考官网 ：http://atlas.apache.org/#/BuildInstallation
下载解压 源码
...
atlas架构及原理
介绍Atlas 是Hadoop的数据治理和元数据框架，是一组可伸缩和可扩展的核心基础治理服务。
Atlas 提供开放的元数据管理和治理功能，以构建数据资产的目录，对这些资产进行分类和治理，并为数据科学家、分析师和数据治理团队提供围绕这些数据资产的协作功能。
特性
Metadata types &a
...
Flink任务提交流程分析
任务启动启动流程见 $FLINK_HOME/bin/flink
可见其启动入口类为：org.apache.flink.client.cli.CliFrontendCliFrontend 任务入口类main方法1234567891011121314151617181920212223242526272
...
副本攻略
副本（Replica）攻略在分布式系统中，副本是最常见的概念之一，一般指的是对数据或服务的冗余方式。数据副本是在不同的节点上持久化存储同一份数据，防止数据丢失；服务副本指的是多个节点提供同样的服务，单节点挂掉不影响正常服务。
Kafka 中的副本相关：
副本是特定分区 Partition 的副本
...
Flink集群搭建
环境配置1. JAVA环境卸载OpenJDK，安装OracleJDK
rpm -aq | grep java 命令 查看本地安装的JDK软件包
1234[root@localhost ~]# rpm -aq | grep javatzdata-java-2016c-1.el6.noarchjava-
...