2024年【kafka专栏】生产者客户端自定义分区器实现向指定分区发送消息，java面试官经验心得_kafka生产者 向指定分区发送消息

最后

本人也收藏了一份Java面试核心知识点来应付面试，借着这次机会可以送给我的读者朋友们:

目录：

Java面试核心知识点

一共有30个专题，足够读者朋友们应付面试啦，也节省朋友们去到处搜刮资料自己整理的时间！

Java面试核心知识点

本文已被CODING开源项目：【一线大厂Java面试题解析+核心总结学习笔记+最新讲解视频+实战项目源码】收录

需要这份系统化的资料的朋友，可以点击这里获取

kafka生产者的数据生产流程中，有三个环节是我们可以自定义的，如下图所示。本文为大家介绍如何自定义kafka生产者分区器。

一、生产者默认分区策略

---

分区策略作用就是指消息根据什么规则，被发往主题的哪个分区。

• 默认策略一：如果生产者指定了partition分区，就直接发送到该partition分区

• 默认策略二：如果没有指定分区但是指定了key，就按照key的hash值选择分区，具有相同key值的消息将被发往同一个分区。

• 默认策略三：如果partition和key都没有指定就使用轮询策略，能保证消息相对均衡的分配给同一个主题下的多个分区。

二、消息有序性的保障

---

一再说明的是“消息是按照主题分区进行发送的”，所以如果希望保证消息数据发送的有序性，以及消费者消费数据的有序性，就必须将这些消息发往同一个分区。

怎么发往同一个分区？三种方法：

• 生产者指定par

最后

这份清华大牛整理的进大厂必备的redis视频、面试题和技术文档

祝大家早日进入大厂，拿到满意的薪资和职级~~~加油！！

感谢大家的支持！！

本文已被CODING开源项目：【一线大厂Java面试题解析+核心总结学习笔记+最新讲解视频+实战项目源码】收录

需要这份系统化的资料的朋友，可以点击这里获取

朋友，可以点击这里获取](https://bbs.csdn.net/forums/4f45ff00ff254613a03fab5e56a57acb)**