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)¶
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)¶