在本教程中，我们将探索基于固定最大大小对 Java 8 的 Stream 进行分区的各种技术。

我们将首先重新审视如何使用 List 来完成这项工作。随后，我们将通过引入 Stream 特有的功能，如延迟评估和线程安全性，来增强我们的方法。

2. List 的分区

在 Java 中，有多种分区 List 的方法。一种简单的方法是首先根据所需的批量大小和源列表的大小来确定所需的批次数量：

static ```````````<T>``````````` Stream<List```````````<T>```````````> partitionList(List```````````<T>``````````` source, int batchSize) {
    int nrOfFullBatches = (source.size() - 1) / batchSize;
    // ...
}

在本教程中，我们将探讨Kafka主题和分区以及它们之间的关联。

1. 引言

在本教程中，我们将探讨Kafka主题和分区以及它们是如何相互关联的。

2. Kafka主题是什么

主题是一个存储事件序列的机制。 从根本上说，主题是持久的日志文件，它们按照事件发生的时间顺序保持事件的顺序。因此，每个新事件总是被添加到日志的末尾。此外，事件是不可变的。因此，一旦事件被添加到主题中，我们就不能更改它们。

Kafka主题的一个示例用例是记录一个房间的温度测量序列。一旦记录了温度值，比如下午5:02的25摄氏度，它就不能被改变，因为它已经发生了。此外，下午5:06的温度值不能早于在下午5:02记录的温度值。因此，通过将每个温度测量视为一个事件，Kafka主题将是存储该数据的合适选择。