kafka.partitioner package¶
Submodules¶
kafka.partitioner.base module¶
kafka.partitioner.hashed module¶
-
kafka.partitioner.hashed.
HashedPartitioner
¶ alias of
LegacyPartitioner
-
class
kafka.partitioner.hashed.
LegacyPartitioner
(partitions)[source]¶ Bases:
kafka.partitioner.base.Partitioner
DEPRECATED – See Issue 374
Implements a partitioner which selects the target partition based on the hash of the key
-
class
kafka.partitioner.hashed.
Murmur2Partitioner
(partitions)[source]¶ Bases:
kafka.partitioner.base.Partitioner
Implements a partitioner which selects the target partition based on the hash of the key. Attempts to apply the same hashing function as mainline java client.
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
-
kafka.partitioner.
HashedPartitioner
¶ alias of
LegacyPartitioner
-
class
kafka.partitioner.
Murmur2Partitioner
(partitions)[source]¶ Bases:
kafka.partitioner.base.Partitioner
Implements a partitioner which selects the target partition based on the hash of the key. Attempts to apply the same hashing function as mainline java client.
-
class
kafka.partitioner.
LegacyPartitioner
(partitions)[source]¶ Bases:
kafka.partitioner.base.Partitioner
DEPRECATED – See Issue 374
Implements a partitioner which selects the target partition based on the hash of the key