Interface StreamsPartitioner
-
- All Superinterfaces:
Configurable
- All Known Implementing Classes:
DefaultStreamsPartitioner
public interface StreamsPartitioner extends Configurable
Partitioner Interface
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
close()
This is called when partitioner is closed.int
partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, int numPartitions)
Compute the partition for the given record.-
Methods inherited from interface org.apache.kafka.common.Configurable
configure
-
-
-
-
Method Detail
-
partition
int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, int numPartitions)
Compute the partition for the given record.- Parameters:
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 has
-
close
void close()
This is called when partitioner is closed.
-
-