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 and Description
void	close() This is called when partitioner is closed.
int	partition(java.lang.String topic, java.lang.Object key, byte[] keyBytes, java.lang.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(java.lang.String topic,
              java.lang.Object key,
              byte[] keyBytes,
              java.lang.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.