Package com.pulumi.aws.dms.inputs

Class EndpointKafkaSettingsArgs

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

    • Method Detail

      • broker

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

      • includeControlDetails

        public java.util.Optional<com.pulumi.core.Output<java.lang.Boolean>> includeControlDetails()
        Returns:
        Shows detailed control information for table definition, column definition, and table and column changes in the Kafka message output. Default is `false`.

      • includeNullAndEmpty

        public java.util.Optional<com.pulumi.core.Output<java.lang.Boolean>> includeNullAndEmpty()
        Returns:
        Include NULL and empty columns for records migrated to the endpoint. Default is `false`.

      • includePartitionValue

        public java.util.Optional<com.pulumi.core.Output<java.lang.Boolean>> includePartitionValue()
        Returns:
        Shows the partition value within the Kafka message output unless the partition type is `schema-table-type`. Default is `false`.

      • includeTableAlterOperations

        public java.util.Optional<com.pulumi.core.Output<java.lang.Boolean>> includeTableAlterOperations()
        Returns:
        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`.

      • includeTransactionDetails

        public java.util.Optional<com.pulumi.core.Output<java.lang.Boolean>> includeTransactionDetails()
        Returns:
        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`.

      • messageFormat

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> messageFormat()
        Returns:
        Output format for the records created on the endpoint. Message format is `JSON` (default) or `JSON_UNFORMATTED` (a single line with no tab).

      • messageMaxBytes

        public java.util.Optional<com.pulumi.core.Output<java.lang.Integer>> messageMaxBytes()
        Returns:
        Maximum size in bytes for records created on the endpoint Default is `1,000,000`.

      • noHexPrefix

        public java.util.Optional<com.pulumi.core.Output<java.lang.Boolean>> noHexPrefix()
        Returns:
        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.

      • partitionIncludeSchemaTable

        public java.util.Optional<com.pulumi.core.Output<java.lang.Boolean>> partitionIncludeSchemaTable()
        Returns:
        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`.

      • saslMechanism

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> saslMechanism()
        Returns:
        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`.

      • saslPassword

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> saslPassword()
        Returns:
        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.

      • saslUsername

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> saslUsername()
        Returns:
        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.

      • securityProtocol

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> securityProtocol()
        Returns:
        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`.

      • sslCaCertificateArn

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> sslCaCertificateArn()
        Returns:
        ARN for the private certificate authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint.

      • sslClientCertificateArn

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> sslClientCertificateArn()
        Returns:
        ARN of the client certificate used to securely connect to a Kafka target endpoint.

      • sslClientKeyArn

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> sslClientKeyArn()
        Returns:
        ARN for the client private key used to securely connect to a Kafka target endpoint.

      • sslClientKeyPassword

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> sslClientKeyPassword()
        Returns:
        Password for the client private key used to securely connect to a Kafka target endpoint.

      • topic

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> topic()
        Returns:
        Kafka topic for migration. Default is `kafka-default-topic`.