Class AssociationCreateOrUpdateInfo

java.lang.Object
io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

public class AssociationCreateOrUpdateInfo extends Object
  • Constructor Details

  • Method Details

    • getSubject

      public String getSubject()
    • setSubject

      public void setSubject(String subject)
    • getAssociationType

      public String getAssociationType()
    • setAssociationType

      public void setAssociationType(String associationType)
    • getLifecycle

      public LifecyclePolicy getLifecycle()
    • setLifecycle

      public void setLifecycle(LifecyclePolicy lifecycle)
    • getFrozen

      public Boolean getFrozen()
    • setFrozen

      public void setFrozen(Boolean frozen)
    • getSchema

      public RegisterSchemaRequest getSchema()
    • setSchema

      public void setSchema(RegisterSchemaRequest schema)
    • getNormalize

      public Boolean getNormalize()
    • setNormalize

      public void setNormalize(Boolean normalize)
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • toJson

      public String toJson() throws IOException
      Throws:
      IOException
    • applyDefaults

      public void applyDefaults(boolean isCreate)
      Applies defaults for association creation or upsert. For CREATE: schema implies frozen STRONG; frozen=false or WEAK with schema are rejected. For UPSERT: schema implies non-frozen STRONG; frozen and lifecycle are only defaulted if null.
    • validate

      public void validate(boolean isCreate, boolean dryRun)