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

public class SimplePartitioner implements Partitioner {
    public SimplePartitioner (VerifiableProperties props) {

    }

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

}

<dependency>
	<groupId>org.slf4j</groupId>
	<artifactId>slf4j-simple</artifactId>
	<version>1.6.2</version>
</dependency

bin/kafka-topics.sh --create --topic page_visits --replication-factor  1 --zookeeper localhost:2181 --partition 5
 bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic page_visits --from-beginning
developer@vagrant-ubuntu-precise-64:~/tools/kafka_2.10-0.8.1.1$ bin/kafka-topics.sh --zookeeper localhost:2181 --describe page_visits
Topic:page_visits       PartitionCount:5        ReplicationFactor:1     Configs:
        Topic: page_visits      Partition: 0    Leader: 0       Replicas: 0     Isr: 0
        Topic: page_visits      Partition: 1    Leader: 0       Replicas: 0     Isr: 0
        Topic: page_visits      Partition: 2    Leader: 0       Replicas: 0     Isr: 0
        Topic: page_visits      Partition: 3    Leader: 0       Replicas: 0     Isr: 0
        Topic: page_visits      Partition: 4    Leader: 0       Replicas: 0     Isr: 0
Topic:testing   PartitionCount:1        ReplicationFactor:1     Configs:
        Topic: testing  Partition: 0    Leader: 0       Replicas: 0     Isr: 0
bin/kafka-topics.sh --zookeeper localhost:2181 --describe page_visits


bin/kafka-topics.sh --zookeeper localhost:2181 --list