java kafka生产者通过实现partitioner接口可自定义分区逻辑，如按用户id地域、订单类型或负载动态路由；需正确实现partition()方法并确保返回合法分区号，配置时指定partitoner.class参数。
Java Kafka 生产者通过实现 org.apache.kafka.clients.producer.Partitioner 接口，就能完全控制消息发往哪个分区，从而按业务规则做精准路由——比如按用户 ID 归属地域分片、按订单类型隔离、或避开高负载分区。
定义分区器类：实现核心逻辑
自定义分区器必须实现三个方法，其中 partition() 是关键。它接收消息的 topic、key、value 及集群元数据（Cluster），返回目标分区编号（从 0 开始）。
常见业务路由逻辑示例：
- 按 value 中的字段路由：如解析 JSON 字符串，提取
"region": "shanghai"，映射到固定分区 - 按 key 做一致性哈希：避免扩容时大量 key 重分配，比默认 murmur2 更稳定
- 按时间维度分流：如把日志按小时哈希到不同分区，便于下游按时间窗口消费
- 动态感知负载：查
cluster.availablePartitionsForTopic(topic)，跳过 leader 不在本地 Broker 的分区，降低网络开销
配置生产者使用该分区器
只需在 Properties 中设置 partitioner.class 参数为你的全限定类名：
props.put(ProducerConfig.PARTITIONER_CLASS_CONFIG, "com.example.MyRegionAwarePartitioner");
注意：不要手动 new 分区器实例，Kafka 会通过反射创建并调用 configure() 注入配置参数；若需传参（如 region 映射表），可在 configure(Map<string> configs)</string> 中读取 configs.get("region.mapping") 等自定义键。
保证分区号合法且稳定
返回值必须是 [0, numPartitions) 范围内的整数，否则抛出 IllegalArgumentException。获取当前分区总数推荐方式：
-
cluster.partitionsForTopic(topic).size()—— 安全，自动适配 topic 分区变更 - 避免硬编码或缓存分区数，否则扩容后可能越界或路由倾斜
- 若业务要求相同用户 ID 总进同一分区，确保 key 不为 null，且 hash 计算逻辑与消费者侧一致（如都用 UTF-8 编码再 murmur2）
测试与上线前检查项
上线前建议验证以下几点：
- 用测试 producer 发送一批带不同 key/value 的消息，查
kafka-topics.sh --describe确认分区分布符合预期 - 模拟 topic 新增分区，确认分区器能动态识别新数量（不依赖静态配置）
- 在
close()中释放资源（如关闭连接池、清空缓存），防止内存泄漏 - 若涉及外部依赖（如 Redis 查地域配置），增加超时和降级逻辑，避免阻塞生产者主线程
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
