Kafka生产者分区策略和数据可靠性保证

分区策略 分区原因： 方便集群扩展，每个Partition可以通过调整大小以适应它所在的机器，而一个 topic又可以由多个 Partition组成，因此整个集群就可以适应任意大小的数据。 可以提高并发，分区之后就可以以Partition为单位读写。 分区原则：我们需要将 producer 发送的数据封装成一个 ProducerRecord 对象。 指明 partition 的情况下，直接将指明的

>>阅读原文<<