UniformStickyPartitioner (clients 7.4.13-ce API)

java.lang.Object
- org.apache.kafka.clients.producer.UniformStickyPartitioner

All Implemented Interfaces:
Closeable, AutoCloseable, Partitioner, Configurable
Deprecated.
```
@Deprecated
public class UniformStickyPartitioner
extends Object
implements Partitioner
```
NOTE this partitioner is deprecated and shouldn't be used. To use default partitioning logic remove partitioner.class configuration setting and set partitioner.ignore.keys=true. See KIP-794 for more info. The partitioning strategy:
- If a partition is specified in the record, use it
- Otherwise choose the sticky partition that changes when the batch is full. NOTE: In contrast to the DefaultPartitioner, the record key is NOT used as part of the partitioning strategy in this partitioner. Records with the same key are not guaranteed to be sent to the same partition. See KIP-480 for details about sticky partitioning.

Constructor Summary
Constructors
Constructor and Description
UniformStickyPartitioner()
Deprecated.

Constructors
Constructor and Description
`UniformStickyPartitioner()` Deprecated.

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
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.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - UniformStickyPartitioner
```
public UniformStickyPartitioner()
```
    Deprecated.
- Method Detail
  - configure
```
public void configure(Map<String,?> configs)
```
    Deprecated.
    Description copied from interface: Configurable
    Configure this class with the given key-value pairs
    Specified by:
    configure in interface Configurable
  - partition
```
public int partition(String topic,
                     Object key,
                     byte[] keyBytes,
                     Object value,
                     byte[] valueBytes,
                     Cluster cluster)
```
    Deprecated.
    Compute the partition for the given record.
    Specified by:
    partition in interface 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
  - close
```
public void close()
```
    Deprecated.
    Description copied from interface: Partitioner
    This is called when partitioner is closed.
    Specified by:
    close in interface Closeable
    Specified by:
    close in interface AutoCloseable
    Specified by:
    close in interface Partitioner
  - onNewBatch
```
public void onNewBatch(String topic,
                       Cluster cluster,
                       int prevPartition)
```
    Deprecated.
    If a batch completed for the current sticky partition, change the sticky partition. Alternately, if no sticky partition has been determined, set one.
    Specified by:
    onNewBatch in interface Partitioner
    Parameters:
    topic - The topic name
    cluster - The current cluster metadata
    prevPartition - The partition previously selected for the record that triggered a new batch

Class UniformStickyPartitioner

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

UniformStickyPartitioner

Method Detail

configure

partition

close

onNewBatch