kafka.partitioner package

Submodules

kafka.partitioner.base module

class kafka.partitioner.base.Partitioner(partitions)

Bases: object

Base class for a partitioner

partition(key, partitions=None)

Takes a string key and num_partitions as argument and returns a partition to be used for the message

Parameters:

• key – the key to use for partitioning
• partitions – (optional) a list of partitions.

kafka.partitioner.hashed module

class kafka.partitioner.hashed.HashedPartitioner(partitions)

Bases: kafka.partitioner.base.Partitioner

Implements a partitioner which selects the target partition based on the hash of the key

partition(key, partitions=None)

kafka.partitioner.roundrobin module

class kafka.partitioner.roundrobin.RoundRobinPartitioner(partitions)

Bases: kafka.partitioner.base.Partitioner

Implements a round robin partitioner which sends data to partitions in a round robin fashion

partition(key, partitions=None)

Module contents

class kafka.partitioner.RoundRobinPartitioner(partitions)

Bases: kafka.partitioner.base.Partitioner

Implements a round robin partitioner which sends data to partitions in a round robin fashion

partition(key, partitions=None)

class kafka.partitioner.HashedPartitioner(partitions)

Bases: kafka.partitioner.base.Partitioner

Implements a partitioner which selects the target partition based on the hash of the key

partition(key, partitions=None)