Partitioner

class kafka.partitioner.Partitioner[source]
abstract partition(topic, key, serialized_key, value, serialized_value, cluster)[source]