kafka采用拉取模型，由消费者自己记录消费状态，每个消费者互相独立地顺序拉取每个分区的消息，消费者可以按照任意的顺序消费消息。比如，消费者可以重置到旧的偏移量，重新处理之前已经消费过的消息；或者直接跳到最近的位置，从当前的时刻开始消费。查看全文>>

“跨域”指的是浏览器不能执行其他网站的脚本，它是由浏览器的同源策略造成的，是浏览器对javascript施加的安全限制，防止他人恶意攻击网站。查看全文>>

leader对于消息的写入以及读取是非常关键的，此时有两个疑问：Kafka如何确定某个partition是leader、哪个partition是follower呢？某个leader崩溃了，如何快速确定另外一个leader呢？使用Kafka Eagle找到某个partition的leader，再找到leader所在的broker。在Linux中强制杀掉该Kafka的进程，然后观察leader的情况。查看全文>>

我们可以让Kafka根据消费组中的消费者动态地为topic分配要消费的分区。但在某些时候，我们需要指定要消费的分区，这时候就要手动消费分区中的数据，下面来看一下分区方法。查看全文>>

匿名内部类是没有名称的内部类。在Java中调用某个方法时，如果该方法的参数是接口类型，除了可以传人个接口实现类外，还可以使用实现接口的匿名内部类作为参数，在匿名内部类中直接完成方法的实现。创建匿名内部类的基本语法格式如下:查看全文>>

本套课程将介绍什么是面向对象，然后从ES6类面向对象语法，面向对象案例，原型和原型链，如何利用组合继承模拟类的继承。高阶函数，call、apply、bind 的使用，严格模式、闭包、递归函数、正则表达式、ES6新语法。查看全文>>