from abc import ABC, abstractmethod [docs] class Partitioner(ABC): [docs] @abstractmethod def partition(self, topic, key, serialized_key, value, serialized_value, cluster): pass