前言
正常情况下，消费端在编写代码消费某个topic的数据时，只需要填写kafka的服务地址、端口号，然后再在代码中指定topic名称即可，但是在这种情况下，消费端是无需关心具体从topic的哪个分区下消费数据的；
但是在某些业务场景下，比如上游生产者希望通过分区将不同类型的业务数据发送到不同的分区，而对下游的消费者来说，就需要从指定的分区消费数据；
或者在另一种业务情况下，消费者希望能够顺序消费，那么就可以通过生产端将消息发送到指定的分区下即可；
下面通过具体的代码来实现下
1、生产端代码
生产端为了能实现发送到指定的分区，需要实现一个Partitioner的接口类，然后再在生产者代码中使用这个分区类即可
分区器类
import org.apache.kafka.clients.producer.Partitioner;
import org.apache.kafka.common.Cluster;
import java.util.Map;
public class MyPartioner implements Partitioner {
@Override
public int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster) {
String message = value.toString();
int partition ;
i版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/143304.html
