马老师golang 高性能游戏服务器开发

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{**