[Kafka基礎]--自定義Kafka分區器

在調用Kafka的Producer API時,若是沒有指定分區器,那麼數據將會根據默認分區器的算法均分到各個分區。然而實際的生產環境中,可能Kafka的分區數不止一個(官方建議:Kafka的分區數量應該是Broker數量的整數倍!),因此這時須要咱們自定義分區器。java 本文將從如下幾個方面介紹自定義分區器的實現:算法 一、默認分區器的實現express 二、個人自定義分區器實現apache 三
相關文章
相關標籤/搜索