public interface Partitioner extends Configurable
Modifier and Type | Method and Description |
---|---|
void |
close()
This is called when partitioner is closed.
|
int |
partition(String topic,
Object key,
byte[] keyBytes,
Object value,
byte[] valueBytes,
Cluster cluster)
Compute the partition for the given record.
|
configure
int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster)
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 nullcluster
- The current cluster metadatavoid close()