Class DefaultStreamsPartitioner
- java.lang.Object
-
- org.apache.kafka.clients.producer.DefaultStreamsPartitioner
-
- All Implemented Interfaces:
StreamsPartitioner
,Configurable
public class DefaultStreamsPartitioner extends java.lang.Object implements StreamsPartitioner
-
-
Constructor Summary
Constructors Constructor Description DefaultStreamsPartitioner()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
This is called when partitioner is closed.void
configure(java.util.Map<java.lang.String,?> configs)
Configure this class with the given key-value pairsint
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.
-
-
-
Method Detail
-
configure
public void configure(java.util.Map<java.lang.String,?> configs)
Description copied from interface:Configurable
Configure this class with the given key-value pairs- Specified by:
configure
in interfaceConfigurable
-
partition
public 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.- Specified by:
partition
in interfaceStreamsPartitioner
- 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
public void close()
This is called when partitioner is closed.- Specified by:
close
in interfaceStreamsPartitioner
-
-