Class AssociationPayload

java.lang.Object
io.confluent.kafka.odyssey.AssociationPayload
public class AssociationPayload extends Object
Jackson-deserialisable representation of the JSON value supplied by the user for confluent.key.association / confluent.value.association config keys.

Unknown JSON fields are ignored so that new SR features can be used without requiring a broker upgrade (@JsonIgnoreProperties(ignoreUnknown = true)).

  • Constructor Details

    • AssociationPayload

      public AssociationPayload()

  • Method Details

    • getSubject

      public String getSubject()

    • setSubject

      public void setSubject(String subject)

    • getLifecycle

      public String getLifecycle()

    • setLifecycle

      public void setLifecycle(String lifecycle)

    • getSchemaType

      public String getSchemaType()

    • setSchemaType

      public void setSchemaType(String schemaType)

    • getSchema

      public String getSchema()

    • setSchema

      public void setSchema(String schema)

    • getMetadata

      public io.confluent.kafka.schemaregistry.client.rest.entities.Metadata getMetadata()

    • setMetadata

      public void setMetadata(io.confluent.kafka.schemaregistry.client.rest.entities.Metadata metadata)

    • getRuleSet

      public io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet getRuleSet()

    • setRuleSet

      public void setRuleSet(io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet ruleSet)

    • getReferences

      public List<io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference> getReferences()

    • setReferences

      public void setReferences(List<io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference> references)

    • getSchemaTagsToAdd

      public List<io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags> getSchemaTagsToAdd()

    • setSchemaTagsToAdd

      public void setSchemaTagsToAdd(List<io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags> schemaTagsToAdd)

    • getSchemaTagsToRemove

      public List<io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags> getSchemaTagsToRemove()

    • setSchemaTagsToRemove

      public void setSchemaTagsToRemove(List<io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags> schemaTagsToRemove)

    • getNormalize

      public Boolean getNormalize()

    • setNormalize

      public void setNormalize(Boolean normalize)