Interface S3DestinationConfiguration.Builder

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

  • Method Details

    • dataFreshnessInSeconds

      S3DestinationConfiguration.Builder dataFreshnessInSeconds(Integer dataFreshnessInSeconds)

      The maximum time, in seconds, that records buffer in MSK before being flushed to the destination. Allowed range: 300 to 900. Default: 600.

      Parameters:
      dataFreshnessInSeconds - The maximum time, in seconds, that records buffer in MSK before being flushed to the destination. Allowed range: 300 to 900. Default: 600.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • deadLetterQueueS3

      S3DestinationConfiguration.Builder deadLetterQueueS3(DeadLetterQueueS3 deadLetterQueueS3)

      The Amazon S3 bucket and prefix where MSK writes records that fail to deliver.

      Parameters:
      deadLetterQueueS3 - The Amazon S3 bucket and prefix where MSK writes records that fail to deliver.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • deadLetterQueueS3

      default S3DestinationConfiguration.Builder deadLetterQueueS3(Consumer<DeadLetterQueueS3.Builder> deadLetterQueueS3)

      The Amazon S3 bucket and prefix where MSK writes records that fail to deliver.

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

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to deadLetterQueueS3(DeadLetterQueueS3).

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

    • serviceExecutionRoleArn

      S3DestinationConfiguration.Builder serviceExecutionRoleArn(String serviceExecutionRoleArn)

      The Amazon Resource Name (ARN) of the IAM role that MSK assumes to write to the destination Amazon S3 bucket and the dead-letter bucket.

      Parameters:
      serviceExecutionRoleArn - The Amazon Resource Name (ARN) of the IAM role that MSK assumes to write to the destination Amazon S3 bucket and the dead-letter bucket.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • storage

      S3DestinationConfiguration.Builder storage(S3Storage storage)

      The Amazon S3 bucket, prefix, and storage class for delivered records.

      Parameters:
      storage - The Amazon S3 bucket, prefix, and storage class for delivered records.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • storage

      default S3DestinationConfiguration.Builder storage(Consumer<S3Storage.Builder> storage)

      The Amazon S3 bucket, prefix, and storage class for delivered records.

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

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to storage(S3Storage).

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