public interface Partitioner extends Configurable, java.io.Closeable
Modifier and Type | Method and Description |
---|---|
void |
close()
This is called when partitioner is closed.
|
default void |
onNewBatch(java.lang.String topic,
Cluster cluster,
int prevPartition)
Notifies the partitioner a new batch is about to be created.
|
int |
partition(java.lang.String topic,
java.lang.Object key,
byte[] keyBytes,
java.lang.Object value,
byte[] valueBytes,
Cluster cluster)
Compute the partition for the given record.
|
configure
int partition(java.lang.String topic, java.lang.Object key, byte[] keyBytes, java.lang.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()
close
in interface java.lang.AutoCloseable
close
in interface java.io.Closeable
default void onNewBatch(java.lang.String topic, Cluster cluster, int prevPartition)
topic
- The topic namecluster
- The current cluster metadataprevPartition
- The partition previously selected for the record that triggered a new batch