封装是计算机编程语言中最基本但也十分经典的思想（更严谨地说封装是面向对象设计中的一种思想），例如将一段频繁用到的逻辑写成一个函数的过程，其背后蕴含的其实就是封装的思想。与众多编程语言类似，Scala中也提供了方法和...

alpakka-kafka-consumer的功能描述很简单：向kafka订阅某些topic然后把读到的消息传给akka-streams做业务处理。在kafka-consumer的实现细节上，为了达到高可用、高吞吐的目的，topic又可用划分出多个分区partition。分区是...

alpakka项目是一个基于akka-streams流处理编程工具的scala/java开源项目，通过提供connector连接各种数据源并在akka-streams里进行数据处理。alpakka-kafka就是alpakka项目里的kafka-connector。对于我们来说：可以用alp...

构造器（构造方法）作用：构造对象初始化属性（给对象的属性赋值）Java中构造器方法名和类名保持一致构造方法没有返回值类型构造方法可以重载Scala中构造器主构造方法在声明类的同时，就定义了主构造方法，换言之，类就是主构造方法...

1.return可以省略，Scala会使用函数体的最后一行代码作为返回值2.如果函数体只有一行代码，可以省略花括号3.返回值类型如果能够推断出来，那么可以省略（:和返回值类型一起省略）4.如果有return，则不能省略返回值类型，必须指定5....

难得的是，Kafka的索引组件中应用了二分查找算法，而且社区还针对Kafka自身的特点对其进行了改良。

单例对象是一种特殊的类，有且只有一个实例。和惰性变量一样，单例对象是延迟创建的，当它第一次被使用时才创建。

Scala中的Unit类似于Java中的void Send => Unit 表示一个方法。该方法接收Send类实例，然后执行一段代码逻辑。

关于Springboot Kafka其他配置请参考Springboot2整合Kafka

众所周知，csv文件默认以逗号“,”分割数据，那么在scala命令行里查询的数据：