大数据快速运算（共享）

当接收数据时，它会定期地从Kafka中Topic对应Partition中查询最新的偏移量，再根据偏移量范围在每个batch里面处理数据，然后Spark通过调用Kafka简单的消费者API（即低级API）来读取一定范围的数据。