Java Kafka如何自定义分区器及拦截器实现细节？

本文共计1157个文字，预计阅读时间需要5分钟。

生产者将数据发送到对应的分区有以下几种方式：

（1）指定了partition，直接使用；

（2）未指定partition，但指定了key，通过对key的value进行hash得到一个partition；

（3）未指定partition和key，由系统分配一个partition。

生产者发送到对应的分区有以下几种方式：

（1）指定了patition，则直接使用；(可以查阅对应的java api, 有多种参数)

（2）未指定patition但指定key，通过对key的value进行hash出一个patition；

（3）patition和key都未指定，使用轮询选出一个patition。