import abc


class BaseOutput(metaclass=abc.ABCMeta):
    @abc.abstractmethod
    def send(self, msg: dict, partition: int):
        pass