Kafka自定義分區生產者java-API操作-05

消息存哪個分區上的規則: 首先根據自定義分區,如果沒有自定義分區就根據key的hash,value的hash,如果這倆都沒有,就用輪詢方式.   自定義分區:把所有消息存到1分區 定義一個類實現Partitioner接口,重寫裏面的方法(過時API) package com.buba.kafka; import java.util.Map; import kafka.producer.Partit
相關文章
相關標籤/搜索