馬老師golang 高性能游戲服務器開發(fā)
import kafka.producer.Partitioner;
import kafka.utils.VerifiableProperties;
public class JasonPartitioner<T> implements Partitioner {
** public JasonPartitioner(VerifiableProperties verifiableProperties){}**
** @Override**
** public int partition(Object key, int numPartitions){**
** try{**
標簽：
