一： 忘记root 密码1.  重启 Linux 操作系统2.  重启之后 Linux 在终端状态下回有一连串的环境检查，大概半分钟后会出现一个彩色的GRUB引导界面，会有5秒钟倒计时停留等待，如下图3.  出现上面的界面后键入 e  键，会出现一个彩色的引导，出现下面三个选择   kernel /xen.gz-2.6.28-8.e15   module /vmlinu

Spring Cloud和云计算没有关系，只是一个基于Spring Boot的快速构建分布式系统的工具集。 一 Spring Cloud特点# 约定优于配置# 开箱即用，快速启动# 适用于各种环境，可以部署在PC server或者 云环境# 轻量级的组件# 组件的支持很丰富，功能齐全# 选型中立 二 服务提供者和服务消费者 三 服务发现和注册为什

一 启动HBase master就挂掉2016-11-21 20:14:06,926 FATAL [master:hadoop09-linux:60000] master.HMaster: Unhandled exception. Starting shutdown.org.apache.hadoop.ipc.RemoteException(java.io.IOException): Fi

什么是链接？链接简单说实际上是一种文件共享的方式，是 POSIX 中的概念，主流文件系统都支持链接文件。它是用来干什么的？你可以将链接简单地理解为 Windows 中常见的快捷方式（或是 OS X 中的替身），Linux 中常用它来解决一些库版本的问题，通常也会将一些目录层次较深的文件链接到一个更易访问的目录中。在这些用途上，我们通常会使用到软链

ConsumerNetworkClient 是对NetworkClient的一个封装，提供了额外的一些功能，首先我们看一下它有哪些属性：# NetworkClientprivate final KafkaClient client; # 等待被发送的请求队列private final Map> unsent = new HashMap # 元数据信息private

KafkaConsumer从Kafka拉取消息的时候发送的请求时FetchRequest，在其中需要指定消费者希望拉取的起始消息的offset。为了消费者快速获取这个值，KafkaConsumer使用SubscriptionState来追踪TopicPartition与offset的关系：一 SubscriptionTypeNONE: 没有状态AUTO_TOPICS：按照指

MetadataCache 是broker用来缓存当前集群中所有分区状态的组件，他需要通过KafkaController通过向集群中的broker发送UpdateMetadataRequest请求来更新MetadataCache中缓存的数据，每一个broker在收到请求后会异步更新MetadataCache中的数据 一 核心字段brokerId:Int 对应的broker的id

# Kafka使用日志文件的方式保存生产者发送的消息# 每一条消息都有一个offset值来表示它在分区中的偏移量，注意这个offset是一个逻辑值，并不是消息实际物理存储地址；它更加类似于数据库表中的主键，主键唯一却定了数据库表中的记录，offset也唯一却定了分区中的一条消息，逻辑图如下：

KafkaController会通过zookeeper监控整个Kafka集群的运行状态，响应管理员的指令，通过在指定znode添加listener, 监听该znode的数据或者子节点等变化一 TopicChangeListenerdef handleChildChange(parentPath : String, children : java.util.List[String

我们知道每一个topic有多个分区，这些分区leader副本分布在不同的broker上，分区的数量和leader副本可能是动态变化的。比如有可能增加topic的分区数以提高topic的并行处理能力或者leader所在副本宕机导致重新选举新的leader副本对外提供服务。 我们在创建ProducerRecord中的时候我们可以指定分区，也可以不指定分区，当不指定分区的时候，KafkaProd