Class RecordSchemaValidatorConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.confluent.kafka.schemaregistry.validator.RecordSchemaValidatorConfig
public class RecordSchemaValidatorConfig extends org.apache.kafka.common.config.AbstractConfig

  • Field Details

  • Constructor Details

    • RecordSchemaValidatorConfig

      public RecordSchemaValidatorConfig(Map<?,?> props)

    • RecordSchemaValidatorConfig

      public RecordSchemaValidatorConfig(org.apache.kafka.common.config.ConfigDef configDef, Map<?,?> props)

  • Method Details

    • baseRecordSchemaValidatorConfigDef

      public static org.apache.kafka.common.config.ConfigDef baseRecordSchemaValidatorConfigDef()

    • getSamplesPerMin

      public long getSamplesPerMin()

    • getSchemaRegistryUrls

      public List<String> getSchemaRegistryUrls()

    • keySubjectNameStrategy

      public io.confluent.kafka.serializers.subject.strategy.SubjectNameStrategy keySubjectNameStrategy()

    • valueSubjectNameStrategy

      public io.confluent.kafka.serializers.subject.strategy.SubjectNameStrategy valueSubjectNameStrategy()

    • validateKey

      public boolean validateKey()

    • validateValue

      public boolean validateValue()

    • getSchemaValidationContextName

      public String getSchemaValidationContextName()

    • getEnableGuidSchemaValidation

      public Boolean getEnableGuidSchemaValidation()

    • getMaxCacheSize

      public int getMaxCacheSize()

    • getMaxRetries

      public int getMaxRetries()

    • getRetriesWaitMs

      public int getRetriesWaitMs()

    • getMaxIdQueryRange

      public int getMaxIdQueryRange()

    • getBadIdCacheTtl

      public long getBadIdCacheTtl()

    • getBadSchemaCacheTtl

      public long getBadSchemaCacheTtl()