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

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

>>阅读原文<<