kafka.partitioner package¶
Submodules¶
kafka.partitioner.base module¶
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
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
Module contents¶
-
class
kafka.partitioner.
RoundRobinPartitioner
(partitions)[source]¶ Bases:
kafka.partitioner.base.Partitioner
Implements a round robin partitioner which sends data to partitions in a round robin fashion
-
class
kafka.partitioner.
HashedPartitioner
(partitions)[source]¶ Bases:
kafka.partitioner.base.Partitioner
Implements a partitioner which selects the target partition based on the hash of the key