Page History

import kafka.producer.Partitioner;
import kafka.utils.VerifiableProperties;

public class SimplePartitioner implements Partitioner<String>Partitioner {
    public SimplePartitioner (VerifiableProperties props) {

    }

    public int partition(StringObject key, int a_numPartitions) {
        int partition = 0;
        String stringKey = (String) key;
        int offset = keystringKey.lastIndexOf('.');
        if (offset > 0) {
           partition = Integer.parseInt( keystringKey.substring(offset+1)) % a_numPartitions;
        }
       return partition;
  }

}