Package com.pulumi.aws.pipes.inputs

Class PipeSourceParametersSelfManagedKafkaParametersArgs

  • public final class PipeSourceParametersSelfManagedKafkaParametersArgs
extends com.pulumi.resources.ResourceArgs

    • Method Detail

      • additionalBootstrapServers

        public java.util.Optional<com.pulumi.core.Output<java.util.List<java.lang.String>>> additionalBootstrapServers()
        Returns:
        Array of server URLs. Maximum number of 2 items, each of maximum length 300.

      • batchSize

        public java.util.Optional<com.pulumi.core.Output<java.lang.Integer>> batchSize()
        Returns:
        Maximum number of records to include in each batch. Maximum value of 10000.

      • consumerGroupId

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> consumerGroupId()
        Returns:
        Name of the destination queue to consume. Maximum value of 200.

      • maximumBatchingWindowInSeconds

        public java.util.Optional<com.pulumi.core.Output<java.lang.Integer>> maximumBatchingWindowInSeconds()
        Returns:
        Maximum length of a time to wait for events. Maximum value of 300.

      • serverRootCaCertificate

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> serverRootCaCertificate()
        Returns:
        ARN of the Secrets Manager secret used for certification.

      • startingPosition

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> startingPosition()
        Returns:
        Position in a stream from which to start reading. Valid values: TRIM_HORIZON, LATEST.

      • topicName

        public com.pulumi.core.Output<java.lang.String> topicName()
        Returns:
        Name of the topic that the pipe will read from. Maximum length of 249.