Kafka生產者分區策略和數據可靠性保證

分區策略 分區原因: 方便集羣擴展,每個Partition可以通過調整大小以適應它所在的機器,而一個 topic又可以由多個 Partition組成,因此整個集羣就可以適應任意大小的數據。 可以提高併發,分區之後就可以以Partition爲單位讀寫。 分區原則:我們需要將 producer 發送的數據封裝成一個 ProducerRecord 對象。 指明 partition 的情況下,直接將指明的
相關文章
相關標籤/搜索