分类：分区类

2020
10-07

Java kafka如何实现自定义分区类和拦截器

生产者发送到对应的分区有以下几种方式：（1）指定了patition，则直接使用；(可以查阅对应的javaapi,有多种参数)（2）未指定patition但指定key，通过对key的value进行hash出一个patition；（3）patition和key都未指定，使用轮询选出一个patition。但是kafka提供了，自定义分区算法的功能,由业务手动实现分布：1、实现一个自定义分区类，CustomPartitioner实现Partitionerimportorg.apache.kafka.clients.producer.Partitioner;i... 继续阅读 >