kafka.partitioner package

Submodules

kafka.partitioner.base module

class kafka.partitioner.base.Partitioner(partitions)[source]

Bases: object

Base class for a partitioner

partition(key, partitions=None)[source]

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)[source]

Bases: kafka.partitioner.base.Partitioner

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

partition(key, partitions=None)[source]

kafka.partitioner.roundrobin module

class kafka.partitioner.roundrobin.RoundRobinPartitioner(partitions)[source]

Bases: kafka.partitioner.base.Partitioner

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

partition(key, partitions=None)[source]

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)