Package org.apache.kafka.clients.producer

Interface StreamsPartitioner

All Superinterfaces:

Configurable

All Known Implementing Classes:

DefaultStreamsPartitioner

public interface StreamsPartitioner
extends Configurable

Partitioner Interface

Method Summary

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 name

key - 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 null

valueBytes - The serialized value to partition on or null

numPartitions - Number of partitions the topic has

close

void close()

This is called when partitioner is closed.