def METHOD_NAME(self, error: Any, message: Any, committable: Mapping[Partition, int]) -> None:
    if message and error is None:
        self.__produced_message_offsets.update(committable)
    if error is not None:
        raise Exception(error.str())