@Deprecated public class UniformStickyPartitioner extends Object implements Partitioner
Constructor and Description |
---|
UniformStickyPartitioner()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Deprecated.
This is called when partitioner is closed.
|
void |
configure(Map<String,?> configs)
Deprecated.
Configure this class with the given key-value pairs
|
void |
onNewBatch(String topic,
Cluster cluster,
int prevPartition)
Deprecated.
If a batch completed for the current sticky partition, change the sticky partition.
|
int |
partition(String topic,
Object key,
byte[] keyBytes,
Object value,
byte[] valueBytes,
Cluster cluster)
Deprecated.
Compute the partition for the given record.
|
public void configure(Map<String,?> configs)
Configurable
configure
in interface Configurable
public int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster)
partition
in interface Partitioner
topic
- The topic namekey
- 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 nullvalueBytes
- serialized value to partition on or nullcluster
- The current cluster metadatapublic void close()
Partitioner
close
in interface Closeable
close
in interface AutoCloseable
close
in interface Partitioner
public void onNewBatch(String topic, Cluster cluster, int prevPartition)
onNewBatch
in interface Partitioner
topic
- The topic namecluster
- The current cluster metadataprevPartition
- The partition previously selected for the record that triggered a new batch