def check_for_message_exception(cls, message_result):
        """
        Makes sure there isn't an error when sending the message.
        Kafka will silently catch exceptions and not bubble them up.

        Parameters
        ----------
        message_result : FutureRecordMetadata
        """
        exception = message_result.exception

        if isinstance(exception, BaseException):
            raise exception
Makes sure there isn't an error when sending the message.
        Kafka will silently catch exceptions and not bubble them up.

        Parameters
        ----------
        message_result : FutureRecordMetadata