public class DefaultStreamsPartitioner extends java.lang.Object implements StreamsPartitioner
Constructor and Description |
---|
DefaultStreamsPartitioner() |
Modifier and Type | Method and Description |
---|---|
void |
close()
This is called when partitioner is closed.
|
void |
configure(java.util.Map<java.lang.String,?> configs)
Configure this class with the given key-value pairs
|
int |
partition(java.lang.String topic,
java.lang.Object key,
byte[] keyBytes,
java.lang.Object value,
byte[] valueBytes,
int numPartitions)
Compute the partition for the given record.
|
public void configure(java.util.Map<java.lang.String,?> configs)
Configurable
configure
in interface Configurable
public int partition(java.lang.String topic, java.lang.Object key, byte[] keyBytes, java.lang.Object value, byte[] valueBytes, int numPartitions)
partition
in interface StreamsPartitioner
topic
- The topic namekey
- The key to partition on (or null if no key)keyBytes
- The serialized key to partition on( or null if no key)value
- The value to partition on or nullvalueBytes
- The serialized value to partition on or nullnumPartitions
- Number of partitions the topic haspublic void close()
close
in interface StreamsPartitioner