-
Notifications
You must be signed in to change notification settings - Fork 17
/
awsdms_CfnEndpoint_KafkaSettingsProperty.go
94 lines (91 loc) · 7.15 KB
/
awsdms_CfnEndpoint_KafkaSettingsProperty.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
package awsdms
// Provides information that describes an Apache Kafka endpoint.
//
// This information includes the output format of records applied to the endpoint and details of transaction and control table data information. For more information about other available settings, see [Using object mapping to migrate data to a Kafka topic](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Kafka.html#CHAP_Target.Kafka.ObjectMapping) in the *AWS Database Migration Service User Guide* .
//
// Example:
// // The code below shows an example of how to instantiate this type.
// // The values are placeholders you should change.
// import "github.com/aws/aws-cdk-go/awscdk"
//
// kafkaSettingsProperty := &kafkaSettingsProperty{
// broker: jsii.String("broker"),
// includeControlDetails: jsii.Boolean(false),
// includeNullAndEmpty: jsii.Boolean(false),
// includePartitionValue: jsii.Boolean(false),
// includeTableAlterOperations: jsii.Boolean(false),
// includeTransactionDetails: jsii.Boolean(false),
// messageFormat: jsii.String("messageFormat"),
// messageMaxBytes: jsii.Number(123),
// noHexPrefix: jsii.Boolean(false),
// partitionIncludeSchemaTable: jsii.Boolean(false),
// saslPassword: jsii.String("saslPassword"),
// saslUserName: jsii.String("saslUserName"),
// securityProtocol: jsii.String("securityProtocol"),
// sslCaCertificateArn: jsii.String("sslCaCertificateArn"),
// sslClientCertificateArn: jsii.String("sslClientCertificateArn"),
// sslClientKeyArn: jsii.String("sslClientKeyArn"),
// sslClientKeyPassword: jsii.String("sslClientKeyPassword"),
// topic: jsii.String("topic"),
// }
//
type CfnEndpoint_KafkaSettingsProperty struct {
// A comma-separated list of one or more broker locations in your Kafka cluster that host your Kafka instance.
//
// Specify each broker location in the form `*broker-hostname-or-ip* : *port*` . For example, `"ec2-12-345-678-901.compute-1.amazonaws.com:2345"` . For more information and examples of specifying a list of broker locations, see [Using Apache Kafka as a target for AWS Database Migration Service](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Kafka.html) in the *AWS Database Migration Service User Guide* .
Broker *string `field:"optional" json:"broker" yaml:"broker"`
// Shows detailed control information for table definition, column definition, and table and column changes in the Kafka message output.
//
// The default is `false` .
IncludeControlDetails interface{} `field:"optional" json:"includeControlDetails" yaml:"includeControlDetails"`
// Include NULL and empty columns for records migrated to the endpoint.
//
// The default is `false` .
IncludeNullAndEmpty interface{} `field:"optional" json:"includeNullAndEmpty" yaml:"includeNullAndEmpty"`
// Shows the partition value within the Kafka message output unless the partition type is `schema-table-type` .
//
// The default is `false` .
IncludePartitionValue interface{} `field:"optional" json:"includePartitionValue" yaml:"includePartitionValue"`
// 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` .
//
// The default is `false` .
IncludeTableAlterOperations interface{} `field:"optional" json:"includeTableAlterOperations" yaml:"includeTableAlterOperations"`
// Provides detailed transaction information from the source database.
//
// This information includes a commit timestamp, a log position, and values for `transaction_id` , previous `transaction_id` , and `transaction_record_id` (the record offset within a transaction). The default is `false` .
IncludeTransactionDetails interface{} `field:"optional" json:"includeTransactionDetails" yaml:"includeTransactionDetails"`
// The output format for the records created on the endpoint.
//
// The message format is `JSON` (default) or `JSON_UNFORMATTED` (a single line with no tab).
MessageFormat *string `field:"optional" json:"messageFormat" yaml:"messageFormat"`
// The maximum size in bytes for records created on the endpoint The default is 1,000,000.
MessageMaxBytes *float64 `field:"optional" json:"messageMaxBytes" yaml:"messageMaxBytes"`
// 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.
NoHexPrefix interface{} `field:"optional" json:"noHexPrefix" yaml:"noHexPrefix"`
// 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. The default is `false` .
PartitionIncludeSchemaTable interface{} `field:"optional" json:"partitionIncludeSchemaTable" yaml:"partitionIncludeSchemaTable"`
// The secure password that you created when you first set up your Amazon MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
SaslPassword *string `field:"optional" json:"saslPassword" yaml:"saslPassword"`
// The secure user name you created when you first set up your Amazon MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
SaslUserName *string `field:"optional" json:"saslUserName" yaml:"saslUserName"`
// Set secure connection to a Kafka target endpoint using Transport Layer Security (TLS).
//
// Options include `ssl-encryption` , `ssl-authentication` , and `sasl-ssl` . `sasl-ssl` requires `SaslUsername` and `SaslPassword` .
SecurityProtocol *string `field:"optional" json:"securityProtocol" yaml:"securityProtocol"`
// The Amazon Resource Name (ARN) for the private certificate authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint.
SslCaCertificateArn *string `field:"optional" json:"sslCaCertificateArn" yaml:"sslCaCertificateArn"`
// The Amazon Resource Name (ARN) of the client certificate used to securely connect to a Kafka target endpoint.
SslClientCertificateArn *string `field:"optional" json:"sslClientCertificateArn" yaml:"sslClientCertificateArn"`
// The Amazon Resource Name (ARN) for the client private key used to securely connect to a Kafka target endpoint.
SslClientKeyArn *string `field:"optional" json:"sslClientKeyArn" yaml:"sslClientKeyArn"`
// The password for the client private key used to securely connect to a Kafka target endpoint.
SslClientKeyPassword *string `field:"optional" json:"sslClientKeyPassword" yaml:"sslClientKeyPassword"`
// The topic to which you migrate the data.
//
// If you don't specify a topic, AWS DMS specifies `"kafka-default-topic"` as the migration topic.
Topic *string `field:"optional" json:"topic" yaml:"topic"`
}