Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement