1.我们先了解lead的主要任务是什么leader作为zookeeper集群的主节点，负责响应所有对zookeeper状态变更的请求，它将每个状态请求进行编号和排序，以保证整个集群内部消息处理的FIFO。 除了这之外，还有心跳接收与处理。2.首先看看lead处理环节主控代码如下case LEADING:LOG.info("LEADING");

首先zookeeper server的位置在代码中org/apache/zookeeper/server这个package下面。之前有说过，zookeeper的启动类是ZookeeperServerMain.java这个类，在这个类中使用了final ZooKeeperServer zkServer = new ZooKeeperServer(txnLog, config.tickTime, co

kafka一个topic会有多个partition，那么生产者怎么确定发送到哪个partition，消费者又怎么确认收取的是哪一个partition的数据呢？要想探究这个问题，我们首先需要确定topic是什么？ topic是用户设定的基于某一类型的消息的抽象。那么用户确定下来消息的topic之后，我们需要完成的是对该topic下的消息进行消费。所以就是说一个topic代表的是一个消息的集合，那么p