import org.apache.spark.{SparkContext, SparkConf}import org.apache.spark.sql.{SaveMode, DataFrame}import scala.collection.mutable.ArrayBufferimport main.asia...

在享用了这么久kafka提供的各种福利后, 咱们也来精进一下,看看kafka的各部分实现,知其然也知一点所以然;题目起得有点大,其实完全是临时起意,希望能坚持下去;本身其实不是java程序员,scala也是半吊子, 但是特别喜欢sc...

这里面最主要的就是accept(key, processors(currentProcessor)) (4) accept: 设置新连接socket的参数后交由Processor处理:

在正式开始扒代码之前, 先来个开胃菜,简单介绍一下kafka的基础组件和一些代码实现中用到的基础类库----Kafka基础组件概述KafkaServer是整个Kafka的核心组件，里面包含了ka...

可以看到使用FileMessageSet来操作Log文件, 使用OffsetIndex来操作Index文件

我们使用Kafka, 最终都是要存,取消息,今天我们就来看下源码中和消息相关的类;涉及到的类: MessageRecordMessageSetByteBufferMessageSetBuf

上面这段代码是可以通过编译运行的，可能有些小伙伴会比较困惑，为虾米这里printA函数明明需要接受的是一个A类型，但是传入的一个int类型仍然能够编译通过。...

开篇先简单介绍一下友元这个概念吧。 在C++之中，类的友元函数是定义在类外部，但它有权访问类的所有私有（private）成员和保护（protected）成员。尽管友元函数的原型有在类的定义中出现过，但是友元函数并不是成员函数。友元可以...

Scala作为一门函数式编程与面向对象完美结合的语言，函数式编程部分也有其独到之处，本文就将针对Scala中关于函数式编程的一些常用基本内容进行介绍；...

在 HTML5 的项目中，我们做了移动端的项目。它有一份非常重要的 meta，用于设置屏