Interface KafkaSchemaRegistryConfig.Builder

All Superinterfaces:
Buildable, CopyableBuilder<KafkaSchemaRegistryConfig.Builder,KafkaSchemaRegistryConfig>, SdkBuilder<KafkaSchemaRegistryConfig.Builder,KafkaSchemaRegistryConfig>, SdkPojo
Enclosing class:
KafkaSchemaRegistryConfig
@Mutable @NotThreadSafe public static interface KafkaSchemaRegistryConfig.Builder extends SdkPojo, CopyableBuilder<KafkaSchemaRegistryConfig.Builder,KafkaSchemaRegistryConfig>

  • Method Details

    • schemaRegistryURI

      KafkaSchemaRegistryConfig.Builder schemaRegistryURI(String schemaRegistryURI)

      The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

      • For Glue schema registries, use the ARN of the registry.

      • For Confluent schema registries, use the URL of the registry.

      Parameters:
      schemaRegistryURI - The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

      • For Glue schema registries, use the ARN of the registry.

      • For Confluent schema registries, use the URL of the registry.

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • eventRecordFormat

      KafkaSchemaRegistryConfig.Builder eventRecordFormat(String eventRecordFormat)

      The record format that Lambda delivers to your function after schema validation.

      • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.

      • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.

      Parameters:
      eventRecordFormat - The record format that Lambda delivers to your function after schema validation.

      • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.

      • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.

      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • eventRecordFormat

      KafkaSchemaRegistryConfig.Builder eventRecordFormat(SchemaRegistryEventRecordFormat eventRecordFormat)

      The record format that Lambda delivers to your function after schema validation.

      • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.

      • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.

      Parameters:
      eventRecordFormat - The record format that Lambda delivers to your function after schema validation.

      • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.

      • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.

      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • accessConfigs

      KafkaSchemaRegistryConfig.Builder accessConfigs(Collection<KafkaSchemaRegistryAccessConfig> accessConfigs)

      An array of access configuration objects that tell Lambda how to authenticate with your schema registry.

      Parameters:
      accessConfigs - An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • accessConfigs

      KafkaSchemaRegistryConfig.Builder accessConfigs(KafkaSchemaRegistryAccessConfig... accessConfigs)

      An array of access configuration objects that tell Lambda how to authenticate with your schema registry.

      Parameters:
      accessConfigs - An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • accessConfigs

      KafkaSchemaRegistryConfig.Builder accessConfigs(Consumer<KafkaSchemaRegistryAccessConfig.Builder>... accessConfigs)

      An array of access configuration objects that tell Lambda how to authenticate with your schema registry.

      This is a convenience method that creates an instance of the KafkaSchemaRegistryAccessConfig.Builder avoiding the need to create one manually via KafkaSchemaRegistryAccessConfig.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to accessConfigs(List<KafkaSchemaRegistryAccessConfig>).

      Parameters:
      accessConfigs - a consumer that will call methods on KafkaSchemaRegistryAccessConfig.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • schemaValidationConfigs

      KafkaSchemaRegistryConfig.Builder schemaValidationConfigs(Collection<KafkaSchemaValidationConfig> schemaValidationConfigs)

      An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.

      Parameters:
      schemaValidationConfigs - An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • schemaValidationConfigs

      KafkaSchemaRegistryConfig.Builder schemaValidationConfigs(KafkaSchemaValidationConfig... schemaValidationConfigs)

      An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.

      Parameters:
      schemaValidationConfigs - An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • schemaValidationConfigs

      KafkaSchemaRegistryConfig.Builder schemaValidationConfigs(Consumer<KafkaSchemaValidationConfig.Builder>... schemaValidationConfigs)

      An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.

      This is a convenience method that creates an instance of the KafkaSchemaValidationConfig.Builder avoiding the need to create one manually via KafkaSchemaValidationConfig.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to schemaValidationConfigs(List<KafkaSchemaValidationConfig>).

      Parameters:
      schemaValidationConfigs - a consumer that will call methods on KafkaSchemaValidationConfig.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also: