Kafka自定义分区生产者java-API操作-05

消息存哪个分区上的规则: 首先根据自定义分区,如果没有自定义分区就根据key的hash,value的hash,如果这俩都没有,就用轮询方式.   自定义分区:把所有消息存到1分区 定义一个类实现Partitioner接口,重写里面的方法(过时API) package com.buba.kafka; import java.util.Map; import kafka.producer.Partit
相关文章
相关标签/搜索