Package org.apache.kafka.clients.producer

Class DefaultStreamsPartitioner

java.lang.Object

org.apache.kafka.clients.producer.DefaultStreamsPartitioner

All Implemented Interfaces:

StreamsPartitioner, Configurable

public class DefaultStreamsPartitioner
extends Object
implements StreamsPartitioner

Constructor Summary

Constructors

Constructor	Description
DefaultStreamsPartitioner()

Method Summary

Modifier and Type	Method	Description
void	close()	This is called when partitioner is closed.
void	configure(Map<String,?> configs)	Configure this class with the given key-value pairs
int	partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, int numPartitions)	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

DefaultStreamsPartitioner

public DefaultStreamsPartitioner()

Method Detail

configure

public void configure(Map<String,?> configs)

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,
                     int numPartitions)

Compute the partition for the given record.

Specified by:

partition in interface StreamsPartitioner

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

public void close()

This is called when partitioner is closed.

Specified by:

close in interface StreamsPartitioner