Package com.pulumi.aws.dms.inputs

Class EndpointKafkaSettingsArgs.Builder

  • Enclosing class:
    EndpointKafkaSettingsArgs
    public static final class EndpointKafkaSettingsArgs.Builder
extends java.lang.Object

    • Method Detail

      • broker

        public EndpointKafkaSettingsArgs.Builder broker​(com.pulumi.core.Output<java.lang.String> broker)
        Parameters:
        broker - Kafka broker location. Specify in the form broker-hostname-or-ip:port.
        Returns:
        builder

      • broker

        public EndpointKafkaSettingsArgs.Builder broker​(java.lang.String broker)
        Parameters:
        broker - Kafka broker location. Specify in the form broker-hostname-or-ip:port.
        Returns:
        builder

      • includeControlDetails

        public EndpointKafkaSettingsArgs.Builder includeControlDetails​(@Nullable
                                                               com.pulumi.core.Output<java.lang.Boolean> includeControlDetails)
        Parameters:
        includeControlDetails - Shows detailed control information for table definition, column definition, and table and column changes in the Kafka message output. Default is `false`.
        Returns:
        builder

      • includeControlDetails

        public EndpointKafkaSettingsArgs.Builder includeControlDetails​(java.lang.Boolean includeControlDetails)
        Parameters:
        includeControlDetails - Shows detailed control information for table definition, column definition, and table and column changes in the Kafka message output. Default is `false`.
        Returns:
        builder

      • includeNullAndEmpty

        public EndpointKafkaSettingsArgs.Builder includeNullAndEmpty​(@Nullable
                                                             com.pulumi.core.Output<java.lang.Boolean> includeNullAndEmpty)
        Parameters:
        includeNullAndEmpty - Include NULL and empty columns for records migrated to the endpoint. Default is `false`.
        Returns:
        builder

      • includeNullAndEmpty

        public EndpointKafkaSettingsArgs.Builder includeNullAndEmpty​(java.lang.Boolean includeNullAndEmpty)
        Parameters:
        includeNullAndEmpty - Include NULL and empty columns for records migrated to the endpoint. Default is `false`.
        Returns:
        builder

      • includePartitionValue

        public EndpointKafkaSettingsArgs.Builder includePartitionValue​(@Nullable
                                                               com.pulumi.core.Output<java.lang.Boolean> includePartitionValue)
        Parameters:
        includePartitionValue - Shows the partition value within the Kafka message output unless the partition type is `schema-table-type`. Default is `false`.
        Returns:
        builder

      • includePartitionValue

        public EndpointKafkaSettingsArgs.Builder includePartitionValue​(java.lang.Boolean includePartitionValue)
        Parameters:
        includePartitionValue - Shows the partition value within the Kafka message output unless the partition type is `schema-table-type`. Default is `false`.
        Returns:
        builder

      • includeTableAlterOperations

        public EndpointKafkaSettingsArgs.Builder includeTableAlterOperations​(@Nullable
                                                                     com.pulumi.core.Output<java.lang.Boolean> includeTableAlterOperations)
        Parameters:
        includeTableAlterOperations - Includes any data definition language (DDL) operations that change the table in the control data, such as `rename-table`, `drop-table`, `add-column`, `drop-column`, and `rename-column`. Default is `false`.
        Returns:
        builder

      • includeTableAlterOperations

        public EndpointKafkaSettingsArgs.Builder includeTableAlterOperations​(java.lang.Boolean includeTableAlterOperations)
        Parameters:
        includeTableAlterOperations - Includes any data definition language (DDL) operations that change the table in the control data, such as `rename-table`, `drop-table`, `add-column`, `drop-column`, and `rename-column`. Default is `false`.
        Returns:
        builder

      • includeTransactionDetails

        public EndpointKafkaSettingsArgs.Builder includeTransactionDetails​(@Nullable
                                                                   com.pulumi.core.Output<java.lang.Boolean> includeTransactionDetails)
        Parameters:
        includeTransactionDetails - Provides detailed transaction information from the source database. This information includes a commit timestamp, a log position, and values for `transactionId`, previous `transactionId`, and `transactionRecordId` (the record offset within a transaction). Default is `false`.
        Returns:
        builder

      • includeTransactionDetails

        public EndpointKafkaSettingsArgs.Builder includeTransactionDetails​(java.lang.Boolean includeTransactionDetails)
        Parameters:
        includeTransactionDetails - Provides detailed transaction information from the source database. This information includes a commit timestamp, a log position, and values for `transactionId`, previous `transactionId`, and `transactionRecordId` (the record offset within a transaction). Default is `false`.
        Returns:
        builder

      • messageFormat

        public EndpointKafkaSettingsArgs.Builder messageFormat​(@Nullable
                                                       com.pulumi.core.Output<java.lang.String> messageFormat)
        Parameters:
        messageFormat - Output format for the records created on the endpoint. Message format is `JSON` (default) or `JSON_UNFORMATTED` (a single line with no tab).
        Returns:
        builder

      • messageFormat

        public EndpointKafkaSettingsArgs.Builder messageFormat​(java.lang.String messageFormat)
        Parameters:
        messageFormat - Output format for the records created on the endpoint. Message format is `JSON` (default) or `JSON_UNFORMATTED` (a single line with no tab).
        Returns:
        builder

      • messageMaxBytes

        public EndpointKafkaSettingsArgs.Builder messageMaxBytes​(@Nullable
                                                         com.pulumi.core.Output<java.lang.Integer> messageMaxBytes)
        Parameters:
        messageMaxBytes - Maximum size in bytes for records created on the endpoint Default is `1,000,000`.
        Returns:
        builder

      • messageMaxBytes

        public EndpointKafkaSettingsArgs.Builder messageMaxBytes​(java.lang.Integer messageMaxBytes)
        Parameters:
        messageMaxBytes - Maximum size in bytes for records created on the endpoint Default is `1,000,000`.
        Returns:
        builder

      • noHexPrefix

        public EndpointKafkaSettingsArgs.Builder noHexPrefix​(@Nullable
                                                     com.pulumi.core.Output<java.lang.Boolean> noHexPrefix)
        Parameters:
        noHexPrefix - Set this optional parameter to true to avoid adding a '0x' prefix to raw data in hexadecimal format. For example, by default, AWS DMS adds a '0x' prefix to the LOB column type in hexadecimal format moving from an Oracle source to a Kafka target. Use the `noHexPrefix` endpoint setting to enable migration of RAW data type columns without adding the `'0x'` prefix.
        Returns:
        builder

      • noHexPrefix

        public EndpointKafkaSettingsArgs.Builder noHexPrefix​(java.lang.Boolean noHexPrefix)
        Parameters:
        noHexPrefix - Set this optional parameter to true to avoid adding a '0x' prefix to raw data in hexadecimal format. For example, by default, AWS DMS adds a '0x' prefix to the LOB column type in hexadecimal format moving from an Oracle source to a Kafka target. Use the `noHexPrefix` endpoint setting to enable migration of RAW data type columns without adding the `'0x'` prefix.
        Returns:
        builder

      • partitionIncludeSchemaTable

        public EndpointKafkaSettingsArgs.Builder partitionIncludeSchemaTable​(@Nullable
                                                                     com.pulumi.core.Output<java.lang.Boolean> partitionIncludeSchemaTable)
        Parameters:
        partitionIncludeSchemaTable - Prefixes schema and table names to partition values, when the partition type is `primary-key-type`. Doing this increases data distribution among Kafka partitions. For example, suppose that a SysBench schema has thousands of tables and each table has only limited range for a primary key. In this case, the same primary key is sent from thousands of tables to the same partition, which causes throttling. Default is `false`.
        Returns:
        builder

      • partitionIncludeSchemaTable

        public EndpointKafkaSettingsArgs.Builder partitionIncludeSchemaTable​(java.lang.Boolean partitionIncludeSchemaTable)
        Parameters:
        partitionIncludeSchemaTable - Prefixes schema and table names to partition values, when the partition type is `primary-key-type`. Doing this increases data distribution among Kafka partitions. For example, suppose that a SysBench schema has thousands of tables and each table has only limited range for a primary key. In this case, the same primary key is sent from thousands of tables to the same partition, which causes throttling. Default is `false`.
        Returns:
        builder

      • saslMechanism

        public EndpointKafkaSettingsArgs.Builder saslMechanism​(@Nullable
                                                       com.pulumi.core.Output<java.lang.String> saslMechanism)
        Parameters:
        saslMechanism - For SASL/SSL authentication, AWS DMS supports the `scram-sha-512` mechanism by default. AWS DMS versions 3.5.0 and later also support the PLAIN mechanism. To use the PLAIN mechanism, set this parameter to `plain`.
        Returns:
        builder

      • saslMechanism

        public EndpointKafkaSettingsArgs.Builder saslMechanism​(java.lang.String saslMechanism)
        Parameters:
        saslMechanism - For SASL/SSL authentication, AWS DMS supports the `scram-sha-512` mechanism by default. AWS DMS versions 3.5.0 and later also support the PLAIN mechanism. To use the PLAIN mechanism, set this parameter to `plain`.
        Returns:
        builder

      • saslPassword

        public EndpointKafkaSettingsArgs.Builder saslPassword​(@Nullable
                                                      com.pulumi.core.Output<java.lang.String> saslPassword)
        Parameters:
        saslPassword - Secure password you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
        Returns:
        builder

      • saslPassword

        public EndpointKafkaSettingsArgs.Builder saslPassword​(java.lang.String saslPassword)
        Parameters:
        saslPassword - Secure password you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
        Returns:
        builder

      • saslUsername

        public EndpointKafkaSettingsArgs.Builder saslUsername​(@Nullable
                                                      com.pulumi.core.Output<java.lang.String> saslUsername)
        Parameters:
        saslUsername - Secure user name you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
        Returns:
        builder

      • saslUsername

        public EndpointKafkaSettingsArgs.Builder saslUsername​(java.lang.String saslUsername)
        Parameters:
        saslUsername - Secure user name you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
        Returns:
        builder

      • securityProtocol

        public EndpointKafkaSettingsArgs.Builder securityProtocol​(@Nullable
                                                          com.pulumi.core.Output<java.lang.String> securityProtocol)
        Parameters:
        securityProtocol - Set secure connection to a Kafka target endpoint using TLS. Options include `ssl-encryption`, `ssl-authentication`, and `sasl-ssl`. `sasl-ssl` requires `saslUsername` and `saslPassword`.
        Returns:
        builder

      • securityProtocol

        public EndpointKafkaSettingsArgs.Builder securityProtocol​(java.lang.String securityProtocol)
        Parameters:
        securityProtocol - Set secure connection to a Kafka target endpoint using TLS. Options include `ssl-encryption`, `ssl-authentication`, and `sasl-ssl`. `sasl-ssl` requires `saslUsername` and `saslPassword`.
        Returns:
        builder

      • sslCaCertificateArn

        public EndpointKafkaSettingsArgs.Builder sslCaCertificateArn​(@Nullable
                                                             com.pulumi.core.Output<java.lang.String> sslCaCertificateArn)
        Parameters:
        sslCaCertificateArn - ARN for the private certificate authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint.
        Returns:
        builder

      • sslCaCertificateArn

        public EndpointKafkaSettingsArgs.Builder sslCaCertificateArn​(java.lang.String sslCaCertificateArn)
        Parameters:
        sslCaCertificateArn - ARN for the private certificate authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint.
        Returns:
        builder

      • sslClientCertificateArn

        public EndpointKafkaSettingsArgs.Builder sslClientCertificateArn​(@Nullable
                                                                 com.pulumi.core.Output<java.lang.String> sslClientCertificateArn)
        Parameters:
        sslClientCertificateArn - ARN of the client certificate used to securely connect to a Kafka target endpoint.
        Returns:
        builder

      • sslClientCertificateArn

        public EndpointKafkaSettingsArgs.Builder sslClientCertificateArn​(java.lang.String sslClientCertificateArn)
        Parameters:
        sslClientCertificateArn - ARN of the client certificate used to securely connect to a Kafka target endpoint.
        Returns:
        builder

      • sslClientKeyArn

        public EndpointKafkaSettingsArgs.Builder sslClientKeyArn​(@Nullable
                                                         com.pulumi.core.Output<java.lang.String> sslClientKeyArn)
        Parameters:
        sslClientKeyArn - ARN for the client private key used to securely connect to a Kafka target endpoint.
        Returns:
        builder

      • sslClientKeyArn

        public EndpointKafkaSettingsArgs.Builder sslClientKeyArn​(java.lang.String sslClientKeyArn)
        Parameters:
        sslClientKeyArn - ARN for the client private key used to securely connect to a Kafka target endpoint.
        Returns:
        builder

      • sslClientKeyPassword

        public EndpointKafkaSettingsArgs.Builder sslClientKeyPassword​(@Nullable
                                                              com.pulumi.core.Output<java.lang.String> sslClientKeyPassword)
        Parameters:
        sslClientKeyPassword - Password for the client private key used to securely connect to a Kafka target endpoint.
        Returns:
        builder

      • sslClientKeyPassword

        public EndpointKafkaSettingsArgs.Builder sslClientKeyPassword​(java.lang.String sslClientKeyPassword)
        Parameters:
        sslClientKeyPassword - Password for the client private key used to securely connect to a Kafka target endpoint.
        Returns:
        builder

      • topic

        public EndpointKafkaSettingsArgs.Builder topic​(@Nullable
                                               com.pulumi.core.Output<java.lang.String> topic)
        Parameters:
        topic - Kafka topic for migration. Default is `kafka-default-topic`.
        Returns:
        builder

      • topic

        public EndpointKafkaSettingsArgs.Builder topic​(java.lang.String topic)
        Parameters:
        topic - Kafka topic for migration. Default is `kafka-default-topic`.
        Returns:
        builder