[Kafka基础]--自定义Kafka分区器

在调用Kafka的Producer API时，若是没有指定分区器，那么数据将会根据默认分区器的算法均分到各个分区。然而实际的生产环境中，可能Kafka的分区数不止一个(官方建议：Kafka的分区数量应该是Broker数量的整数倍！)，因此这时须要咱们自定义分区器。java 本文将从如下几个方面介绍自定义分区器的实现：算法 一、默认分区器的实现express 二、个人自定义分区器实现apache 三

>>阅读原文<<