Class ChannelS3Destination


  • public final class ChannelS3Destination
    extends java.lang.Object
    • Method Detail

      • dataFreshnessInSeconds

        public java.util.Optional<java.lang.Integer> dataFreshnessInSeconds()
        Returns:
        Maximum time, in seconds, that records buffer in MSK before being flushed to the destination. Valid values are between `300` and `900`. Defaults to `600`. Can be updated in place without recreating the channel.
      • deadLetterQueueS3

        public ChannelS3DestinationDeadLetterQueueS3 deadLetterQueueS3()
        Returns:
        Amazon S3 bucket and prefix where MSK writes records that fail to deliver. See `deadLetterQueueS3` Block below.
      • serviceExecutionRoleArn

        public java.lang.String serviceExecutionRoleArn()
        Returns:
        ARN of the IAM role that MSK assumes to write to the destination Amazon S3 bucket and the dead-letter bucket.
      • storage

        public ChannelS3DestinationStorage storage()
        Returns:
        Amazon S3 bucket, prefix, and storage class for delivered records. See `storage` Block below. The following arguments are optional: