【kafka原理】Kafka生产者 (分区策略和ACK应答机制)

分区策略 分区原因 方便再集群中扩展,每个Partition可以通过调整以适应它所在的机器,而一个topic又可以有多个Partition组成,因此整个集群就可以适应任意大小的数据了; 可以提高并发,因为可以以partition为单位读写 分区原则 我们需要将producer发送的数据封装成一个ProducerRecord对象 指明 partition 的情况下,直接将指明的值直接作为 parti
相关文章
相关标签/搜索