zookeeper启动：别离在三台机器上执行：zkServer.sh start查看ZooKeeper状态：zkServer.sh status敞开：zkServer.sh stop

应用过kafka的小伙伴应该都晓得kafka自身是没有治理界面的，所有操作都须要手动执行命令来实现。但有些命令又多又长，如果没有做笔记，别说是老手，就连新手也不肯定能记得住，每次想要应用的时候都要上网搜寻一下。有些崇尚geek精力的人或者感觉命令行才是真爱，但应用一款好用的可视化管理工具真的能够极大的晋升效率。

​ 每当controller产生状态变更时，都会通过调用sendRequestsToBrokers办法发送leaderAndIsrRequest申请，本文次要介绍kafka服务端解决该申请的逻辑和过程。

首先装置scala插件idea的设置外面左侧有一个“Plugins”，搜寻scala相干的插件，此时一开始是找不到的，而后点击“search in repositories”，找到一个“Scala”插件，他的类别是“Language”，在线装即可，他会下载之后装置。装置后如下图:

kafka

Kafka 是支流的音讯流零碎，其中的概念还是比拟多的，上面通过图示的形式来梳理一下 Kafka 的外围概念，以便在咱们的头脑中有一个清晰的意识。根底Kafka (Kafka是什么，次要利用在什么场景?)是一套流解决零碎，能够让后端服务轻松的互相沟通，是微服务架构中罕用的组件。生产者消费者生产者服务 Producer 向 Kafka 发送…

Kafka是最后由Linkedin公司开发，是一个分布式、反对分区的（partition）、多正本的（replica），基于zookeeper协调的分布式音讯零碎，它的最大的个性就是能够实时的解决大量数据以满足各种需要场景：比方基于hadoop的批处理零碎、低提早的实时零碎、storm/Spark流式解决引擎，web/nginx日志、拜访日志，音讯服务等等，…

{代码…}

1.Kafka提供了Producer类作为Java producer的api，该类有sync和async两种发送形式。默认是sync形式，即producer的调用类在音讯真正发送到队列中去当前才返回。（1）Kafka提供的java api中的Producer，底层只是保护该topic到每个broker的连贯，并不是一个传统意义上的连接池。在应用sync形式时，咱们应该本人实现一个连贯…

通过上一课时的介绍咱们理解到，业务线程应用 KafkaProducer.send() 办法发送 message 的时候，会先将其写入RecordAccumulator 中进行缓冲，当 RecordAccumulator 中缓存的 message 达到肯定阈值的时候，会由 IO 线程批量造成申请，发送到 kafka 集群。本课时咱们就重点来看一下 RecordAccumulator 这个缓冲区的构造。