org.cripac.isee.vpe.util.kafka

Class EvenlyDistributingPartitioner

java.lang.Object

org.cripac.isee.vpe.util.kafka.EvenlyDistributingPartitioner

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.clients.producer.Partitioner, org.apache.kafka.common.Configurable

public class EvenlyDistributingPartitioner
extends Object
implements org.apache.kafka.clients.producer.Partitioner

The class EvenlyDistributingPartitioner aims to spread records equally on all partitions of a topic.

Created by Ken Yu on 2017/3/8.

Field Summary

Fields

Modifier and Type	Field and Description
private ConcurrentMap<String,AtomicInteger>	topicCounterMap

Constructor Summary

Constructors

Constructor and Description
EvenlyDistributingPartitioner()

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(Map<String,?> configs)
private int	nextValue(String topic)
int	partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, org.apache.kafka.common.Cluster cluster) Compute the partition for the given record.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

topicCounterMap

private final ConcurrentMap<String,AtomicInteger> topicCounterMap

Constructor Detail

EvenlyDistributingPartitioner

public EvenlyDistributingPartitioner()

Method Detail

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

partition

public int partition(String topic,
                     Object key,
                     byte[] keyBytes,
                     Object value,
                     byte[] valueBytes,
                     org.apache.kafka.common.Cluster cluster)

Compute the partition for the given record.

Specified by:

partition in interface org.apache.kafka.clients.producer.Partitioner

Parameters:

topic - The topic name

key - The key to partition on (or null if no key)

keyBytes - serialized key to partition on (or null if no key)

value - The value to partition on or null

valueBytes - serialized value to partition on or null

cluster - The current cluster metadata

nextValue

private int nextValue(String topic)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.kafka.clients.producer.Partitioner