Kafka之生產者

生產者以什麼樣的策略把消息發到各個分區? 1.分區原因 (1)方便在集羣中擴展,一個topic可以有多個partition組成,而每個partition可以通過調整以適應它所在的機器 (2)可以提高併發,因爲可以以partition爲單位讀寫 2.分區原則 我們需要將生產者發送的數據封裝成一個ProducerRecord對象。 (1)指明partition的情況下,直接將指明的值作爲partiti
相關文章
相關標籤/搜索