docs: 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