v1alpha1

type AmazonMskCluster struct {
	MskClusterARN *string `json:"mskClusterARN,omitempty"`
}

type BrokerAZDistribution string

type BrokerEBSVolumeInfo struct {
	KafkaBrokerNodeID *string `json:"kafkaBrokerNodeID,omitempty"`
	// Contains information about provisioned throughput for EBS storage volumes
	// attached to kafka broker nodes.
	ProvisionedThroughput *ProvisionedThroughput `json:"provisionedThroughput,omitempty"`

	VolumeSizeGB *int64 `json:"volumeSizeGB,omitempty"`
}

type BrokerLogs struct {
	// Details of the CloudWatch Logs destination for broker logs.
	CloudWatchLogs *CloudWatchLogs `json:"cloudWatchLogs,omitempty"`
	// Firehose details for BrokerLogs.
	Firehose *Firehose `json:"firehose,omitempty"`
	// The details of the Amazon S3 destination for broker logs.
	S3 *S3 `json:"s3,omitempty"`
}

type BrokerNodeGroupInfo struct {
	// The distribution of broker nodes across Availability Zones. By default, broker
	// nodes are distributed among the Availability Zones of your Region. Currently,
	// the only supported value is DEFAULT. You can either specify this value explicitly
	// or leave it out.
	BrokerAZDistribution *string `json:"brokerAZDistribution,omitempty"`

	ClientSubnets []*string `json:"clientSubnets,omitempty"`
	// Information about the broker access configuration.
	ConnectivityInfo *ConnectivityInfo `json:"connectivityInfo,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	SecurityGroups []*string `json:"securityGroups,omitempty"`
	// Contains information about storage volumes attached to MSK broker nodes.
	StorageInfo *StorageInfo `json:"storageInfo,omitempty"`

	ZoneIDs []*string `json:"zoneIDs,omitempty"`
}

type BrokerNodeInfo struct {
	AttachedENIID *string `json:"attachedENIID,omitempty"`

	ClientSubnet *string `json:"clientSubnet,omitempty"`

	ClientVPCIPAddress *string `json:"clientVPCIPAddress,omitempty"`
	// Information about the current software installed on the cluster.
	CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"`

	Endpoints []*string `json:"endpoints,omitempty"`
}

type BrokerSoftwareInfo struct {
	ConfigurationARN *string `json:"configurationARN,omitempty"`

	ConfigurationRevision *int64 `json:"configurationRevision,omitempty"`

	KafkaVersion *string `json:"kafkaVersion,omitempty"`
}

type ClientAuthentication struct {
	SASL *SASL `json:"sasl,omitempty"`
	// Details for client authentication using TLS.
	TLS *TLS `json:"tls,omitempty"`
	// Contains information about unauthenticated traffic to the cluster.
	Unauthenticated *Unauthenticated `json:"unauthenticated,omitempty"`
}

type ClientBroker string

type ClientVPCConnection struct {
	Authentication *string `json:"authentication,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Owner *string `json:"owner,omitempty"`

	VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"`
}

type CloudWatchLogs struct {
	Enabled *bool `json:"enabled,omitempty"`

	LogGroup *string `json:"logGroup,omitempty"`
}

type Cluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterSpec   `json:"spec"`
	Status            ClusterStatus `json:"status,omitempty"`
}

type ClusterInfo struct {
	ActiveOperationARN *string `json:"activeOperationARN,omitempty"`
	// Describes the setup to be used for Apache Kafka broker nodes in the cluster.
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`

	ClusterARN *string `json:"clusterARN,omitempty"`

	ClusterName *string `json:"clusterName,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// Information about the current software installed on the cluster.
	CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"`

	CurrentVersion *string `json:"currentVersion,omitempty"`
	// Includes encryption-related information, such as the AWS KMS key used for
	// encrypting data at rest and whether you want MSK to encrypt your data in
	// transit.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`

	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"`
	// The state of an Apache Kafka cluster.
	State *string `json:"state,omitempty"`
	// Contains information about the state of the Amazon MSK cluster.
	StateInfo *StateInfo `json:"stateInfo,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`

	Tags map[string]*string `json:"tags,omitempty"`

	ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty"`

	ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"`
}

type ClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Cluster `json:"items"`
}

type ClusterObservation struct {
	// Information about the brokers.
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`
	// The Amazon Resource Name (ARN) of the cluster.
	ClusterARN *string `json:"clusterARN,omitempty"`
	// Cluster policy version.
	ClusterPolicyVersion *string `json:"clusterPolicyVersion,omitempty"`
	// The state of the cluster. The possible states are ACTIVE, CREATING, DELETING,
	// FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, and UPDATING.
	State *string `json:"state,omitempty"`
}

type ClusterOperationInfo struct {
	ClientRequestID *string `json:"clientRequestID,omitempty"`

	ClusterARN *string `json:"clusterARN,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	EndTime *metav1.Time `json:"endTime,omitempty"`

	OperationARN *string `json:"operationARN,omitempty"`

	OperationState *string `json:"operationState,omitempty"`

	OperationType *string `json:"operationType,omitempty"`
}

type ClusterOperationStep struct {
	StepName *string `json:"stepName,omitempty"`
}

type ClusterOperationStepInfo struct {
	StepStatus *string `json:"stepStatus,omitempty"`
}

type ClusterOperationV2 struct {
	ClusterARN *string `json:"clusterARN,omitempty"`

	EndTime *metav1.Time `json:"endTime,omitempty"`

	OperationARN *string `json:"operationARN,omitempty"`

	OperationState *string `json:"operationState,omitempty"`

	OperationType *string `json:"operationType,omitempty"`

	StartTime *metav1.Time `json:"startTime,omitempty"`
}

type ClusterOperationV2Summary struct {
	ClusterARN *string `json:"clusterARN,omitempty"`

	EndTime *metav1.Time `json:"endTime,omitempty"`

	OperationARN *string `json:"operationARN,omitempty"`

	OperationState *string `json:"operationState,omitempty"`

	OperationType *string `json:"operationType,omitempty"`

	StartTime *metav1.Time `json:"startTime,omitempty"`
}

type ClusterParameters struct {
	// Region is which region the Cluster will be created.
	// +kubebuilder:validation:Required
	Region string `json:"region"`
	// Includes all client authentication related information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// The name of the cluster.
	// +kubebuilder:validation:Required
	ClusterName *string `json:"clusterName"`
	// Includes all encryption-related information.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies the level of monitoring for the MSK cluster. The possible values
	// are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// The version of Apache Kafka.
	// +kubebuilder:validation:Required
	KafkaVersion *string `json:"kafkaVersion"`
	// LoggingInfo details.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`
	// The number of Apache Kafka broker nodes in the Amazon MSK cluster.
	// +kubebuilder:validation:Required
	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes"`
	// The settings for open monitoring.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// This controls storage mode for supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
	// Create tags when creating the cluster.
	Tags                    map[string]*string `json:"tags,omitempty"`
	CustomClusterParameters `json:",inline"`
}

type ClusterSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       ClusterParameters `json:"forProvider"`
}

type ClusterState string

type ClusterStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          ClusterObservation `json:"atProvider,omitempty"`
}

type ClusterType string

type Cluster_SDK struct {
	ActiveOperationARN *string `json:"activeOperationARN,omitempty"`

	ClusterARN *string `json:"clusterARN,omitempty"`

	ClusterName *string `json:"clusterName,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	CurrentVersion *string `json:"currentVersion,omitempty"`
	// The state of an Apache Kafka cluster.
	State *string `json:"state,omitempty"`
	// Contains information about the state of the Amazon MSK cluster.
	StateInfo *StateInfo `json:"stateInfo,omitempty"`

	Tags map[string]*string `json:"tags,omitempty"`
}

type CompatibleKafkaVersion struct {
	SourceVersion *string `json:"sourceVersion,omitempty"`

	TargetVersions []*string `json:"targetVersions,omitempty"`
}

type Configuration struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ConfigurationSpec   `json:"spec"`
	Status            ConfigurationStatus `json:"status,omitempty"`
}

type ConfigurationInfo struct {
	ARN *string `json:"arn,omitempty"`

	Revision *int64 `json:"revision,omitempty"`
}

type ConfigurationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Configuration `json:"items"`
}

type ConfigurationObservation struct {
	// The Amazon Resource Name (ARN) of the configuration.
	ARN *string `json:"arn,omitempty"`
	// The time when the configuration was created.
	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// Latest revision of the configuration.
	LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"`
	// The name of the configuration. Configuration names are strings that match
	// the regex "^[0-9A-Za-z-]+$".
	Name *string `json:"name,omitempty"`
	// The state of the configuration. The possible states are ACTIVE, DELETING
	// and DELETE_FAILED.
	State *string `json:"state,omitempty"`
}

type ConfigurationParameters struct {
	// Region is which region the Configuration will be created.
	// +kubebuilder:validation:Required
	Region string `json:"region"`
	// The description of the configuration.
	Description *string `json:"description,omitempty"`
	// The versions of Apache Kafka with which you can use this MSK configuration.
	KafkaVersions                 []*string `json:"kafkaVersions,omitempty"`
	CustomConfigurationParameters `json:",inline"`
}

type ConfigurationRevision struct {
	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Description *string `json:"description,omitempty"`

	Revision *int64 `json:"revision,omitempty"`
}

type ConfigurationSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       ConfigurationParameters `json:"forProvider"`
}

type ConfigurationState string

type ConfigurationStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          ConfigurationObservation `json:"atProvider,omitempty"`
}

type Configuration_SDK struct {
	ARN *string `json:"arn,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Description *string `json:"description,omitempty"`

	KafkaVersions []*string `json:"kafkaVersions,omitempty"`
	// Describes a configuration revision.
	LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"`

	Name *string `json:"name,omitempty"`
	// The state of a configuration.
	State *string `json:"state,omitempty"`
}

type ConnectivityInfo struct {
	// Broker public access control.
	PublicAccess *PublicAccess `json:"publicAccess,omitempty"`
	// Broker VPC connectivity access control.
	VPCConnectivity *VPCConnectivity `json:"vpcConnectivity,omitempty"`
}

type ConsumerGroupReplication struct {
	DetectAndCopyNewConsumerGroups *bool `json:"detectAndCopyNewConsumerGroups,omitempty"`

	SynchroniseConsumerGroupOffsets *bool `json:"synchroniseConsumerGroupOffsets,omitempty"`
}

type ConsumerGroupReplicationUpdate struct {
	DetectAndCopyNewConsumerGroups *bool `json:"detectAndCopyNewConsumerGroups,omitempty"`

	SynchroniseConsumerGroupOffsets *bool `json:"synchroniseConsumerGroupOffsets,omitempty"`
}

type CustomBrokerNodeGroupInfo struct {
	// +optional
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/ec2/v1beta1.Subnet
	// +crossplane:generate:reference:refFieldName=ClientSubnetRefs
	// +crossplane:generate:reference:selectorFieldName=ClientSubnetSelector
	ClientSubnets []*string `json:"clientSubnets,omitempty"`

	// ClientSubnetRefs is a list of references to Subnets used to set
	// the ClientSubnets.
	// +optional
	ClientSubnetRefs []xpv1.Reference `json:"clientSubnetRefs,omitempty"`

	// ClientSubnetSelector selects references to Subnets used
	// to set the ClientSubnets.
	// +optional
	ClientSubnetSelector *xpv1.Selector `json:"clientSubnetSelector,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	// +optional
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/ec2/v1beta1.SecurityGroup
	// +crossplane:generate:reference:refFieldName=SecurityGroupRefs
	// +crossplane:generate:reference:selectorFieldName=SecurityGroupSelector
	SecurityGroups []*string `json:"securityGroups,omitempty"`

	// SecurityGroupRefs is a list of references to SecurityGroups used to set
	// the SecurityGroups.
	// +optional
	SecurityGroupRefs []xpv1.Reference `json:"securityGroupRefs,omitempty"`

	// SecurityGroupSelector selects references to SecurityGroup used
	// to set the SecurityGroups.
	// +optional
	SecurityGroupSelector *xpv1.Selector `json:"securityGroupSelector,omitempty"`

	// Contains information about storage volumes attached to MSK broker nodes.
	StorageInfo *StorageInfo `json:"storageInfo,omitempty"`

	// ConnectivityInfo Information about the broker access configuration.
	ConnectivityInfo *CustomConnectivityInfo `json:"connectivityInfo,omitempty"`
}

type CustomClusterParameters struct {
	// Information about the brokers
	CustomBrokerNodeGroupInfo *CustomBrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`

	// ClusterPolicy of the MSK cluster.
	ClusterPolicy *common.ResourcePolicy `json:"clusterPolicy,omitempty"`

	// Represents the configuration that you want MSK to use for the cluster.
	CustomConfigurationInfo *CustomConfigurationInfo `json:"configurationInfo,omitempty"`
}

type CustomConfigurationInfo struct {
	// ARN of the configuration to use.
	// +optional
	// +crossplane:generate:reference:type=Configuration
	// +crossplane:generate:reference:extractor=ConfugurationARN()
	ARN *string `json:"arn,omitempty"`

	// ARNRef is a reference to a Kafka Configuration used to set ARN.
	// +optional
	ARNRef *xpv1.Reference `json:"arnRef,omitempty"`

	// ARNSelector selects a reference to a Kafka Configuration used to set ARN.
	// +optional
	ARNSelector *xpv1.Selector `json:"arnSelector,omitempty"`

	Revision *int64 `json:"revision,omitempty"`
}

type CustomConfigurationParameters struct {
	// kafka server configurations
	Properties []string `json:"properties"`
}

type CustomConnectivityInfo struct {
	// Broker public access control.
	PublicAccess *CustomPublicAccess `json:"publicAccess,omitempty"`
	// Broker VPC connectivity access control.
	VPCConnectivity *VPCConnectivity `json:"vpcConnectivity,omitempty"`
}

type CustomPublicAccess struct {
	// Type of the public access control.
	Type *string `json:"type,omitempty"`
}

type EBSStorageInfo struct {
	// Contains information about provisioned throughput for EBS storage volumes
	// attached to kafka broker nodes.
	ProvisionedThroughput *ProvisionedThroughput `json:"provisionedThroughput,omitempty"`

	VolumeSize *int64 `json:"volumeSize,omitempty"`
}

type EncryptionAtRest struct {
	DataVolumeKMSKeyID *string `json:"dataVolumeKMSKeyID,omitempty"`
}

type EncryptionInTransit struct {
	// Client-broker encryption in transit setting.
	ClientBroker *string `json:"clientBroker,omitempty"`

	InCluster *bool `json:"inCluster,omitempty"`
}

type EncryptionInfo struct {
	// The data-volume encryption details.
	EncryptionAtRest *EncryptionAtRest `json:"encryptionAtRest,omitempty"`
	// The settings for encrypting data in transit.
	EncryptionInTransit *EncryptionInTransit `json:"encryptionInTransit,omitempty"`
}

type EnhancedMonitoring string

type ErrorInfo struct {
	ErrorCode *string `json:"errorCode,omitempty"`

	ErrorString *string `json:"errorString,omitempty"`
}

type Firehose struct {
	DeliveryStream *string `json:"deliveryStream,omitempty"`

	Enabled *bool `json:"enabled,omitempty"`
}

type IAM struct {
	Enabled *bool `json:"enabled,omitempty"`
}

type JmxExporter struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

type JmxExporterInfo struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

type KafkaClusterClientVPCConfig struct {
	SecurityGroupIDs []*string `json:"securityGroupIDs,omitempty"`

	SubnetIDs []*string `json:"subnetIDs,omitempty"`
}

type KafkaClusterDescription struct {
	KafkaClusterAlias *string `json:"kafkaClusterAlias,omitempty"`
}

type KafkaClusterSummary struct {
	KafkaClusterAlias *string `json:"kafkaClusterAlias,omitempty"`
}

type KafkaVersion struct {
	Version *string `json:"version,omitempty"`
}

type KafkaVersionStatus string

type LoggingInfo struct {
	// The broker logs configuration for this MSK cluster.
	BrokerLogs *BrokerLogs `json:"brokerLogs,omitempty"`
}

type MutableClusterInfo struct {
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// Information about the broker access configuration.
	ConnectivityInfo *ConnectivityInfo `json:"connectivityInfo,omitempty"`
	// Includes encryption-related information, such as the AWS KMS key used for
	// encrypting data at rest and whether you want MSK to encrypt your data in
	// transit.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	KafkaVersion *string `json:"kafkaVersion,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`

	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
}

type NodeExporter struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

type NodeExporterInfo struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

type NodeInfo struct {
	AddedToClusterTime *string `json:"addedToClusterTime,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	NodeARN *string `json:"nodeARN,omitempty"`
}

type NodeType string

type OpenMonitoring struct {
	// Prometheus settings for open monitoring.
	Prometheus *Prometheus `json:"prometheus,omitempty"`
}

type OpenMonitoringInfo struct {
	// Prometheus settings.
	Prometheus *PrometheusInfo `json:"prometheus,omitempty"`
}

type Prometheus struct {
	// Indicates whether you want to enable or disable the JMX Exporter.
	JmxExporter *JmxExporter `json:"jmxExporter,omitempty"`
	// Indicates whether you want to enable or disable the Node Exporter.
	NodeExporter *NodeExporter `json:"nodeExporter,omitempty"`
}

type PrometheusInfo struct {
	// Indicates whether you want to enable or disable the JMX Exporter.
	JmxExporter *JmxExporterInfo `json:"jmxExporter,omitempty"`
	// Indicates whether you want to enable or disable the Node Exporter.
	NodeExporter *NodeExporterInfo `json:"nodeExporter,omitempty"`
}

type Provisioned struct {
	// Describes the setup to be used for Apache Kafka broker nodes in the cluster.
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// Information about the current software installed on the cluster.
	CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"`
	// Includes encryption-related information, such as the AWS KMS key used for
	// encrypting data at rest and whether you want MSK to encrypt your data in
	// transit.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`

	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`

	ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty"`

	ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"`
}

type ProvisionedRequest struct {
	// Describes the setup to be used for Apache Kafka broker nodes in the cluster.
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// Includes encryption-related information, such as the AWS KMS key used for
	// encrypting data at rest and whether you want MSK to encrypt your data in
	// transit.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`

	KafkaVersion *string `json:"kafkaVersion,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`

	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
}

type ProvisionedThroughput struct {
	Enabled *bool `json:"enabled,omitempty"`

	VolumeThroughput *int64 `json:"volumeThroughput,omitempty"`
}

type PublicAccess struct {
	Type *string `json:"type_,omitempty"`
}

type ReplicationInfo struct {
	SourceKafkaClusterARN *string `json:"sourceKafkaClusterARN,omitempty"`

	TargetKafkaClusterARN *string `json:"targetKafkaClusterARN,omitempty"`
}

type ReplicationInfoDescription struct {
	SourceKafkaClusterAlias *string `json:"sourceKafkaClusterAlias,omitempty"`

	TargetKafkaClusterAlias *string `json:"targetKafkaClusterAlias,omitempty"`
}

type ReplicationInfoSummary struct {
	SourceKafkaClusterAlias *string `json:"sourceKafkaClusterAlias,omitempty"`

	TargetKafkaClusterAlias *string `json:"targetKafkaClusterAlias,omitempty"`
}

type ReplicationStateInfo struct {
	Code *string `json:"code,omitempty"`

	Message *string `json:"message,omitempty"`
}

type ReplicatorState string

type ReplicatorSummary struct {
	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	CurrentVersion *string `json:"currentVersion,omitempty"`

	IsReplicatorReference *bool `json:"isReplicatorReference,omitempty"`

	ReplicatorARN *string `json:"replicatorARN,omitempty"`

	ReplicatorName *string `json:"replicatorName,omitempty"`

	ReplicatorResourceARN *string `json:"replicatorResourceARN,omitempty"`
}

type S3 struct {
	Bucket *string `json:"bucket,omitempty"`

	Enabled *bool `json:"enabled,omitempty"`

	Prefix *string `json:"prefix,omitempty"`
}

type SASL struct {
	IAM *IAM `json:"iam,omitempty"`

	SCRAM *SCRAM `json:"scram,omitempty"`
}

type SCRAM struct {
	Enabled *bool `json:"enabled,omitempty"`
}

type ServerlessSASL struct {
	IAM *IAM `json:"iam,omitempty"`
}

type StateInfo struct {
	Code *string `json:"code,omitempty"`

	Message *string `json:"message,omitempty"`
}

type StorageInfo struct {
	// Contains information about the EBS storage volumes attached to Apache Kafka
	// broker nodes.
	EBSStorageInfo *EBSStorageInfo `json:"ebsStorageInfo,omitempty"`
}

type StorageMode string

type TLS struct {
	CertificateAuthorityARNList []*string `json:"certificateAuthorityARNList,omitempty"`

	Enabled *bool `json:"enabled,omitempty"`
}

type TargetCompressionType string

type TopicReplication struct {
	CopyAccessControlListsForTopics *bool `json:"copyAccessControlListsForTopics,omitempty"`

	CopyTopicConfigurations *bool `json:"copyTopicConfigurations,omitempty"`

	DetectAndCopyNewTopics *bool `json:"detectAndCopyNewTopics,omitempty"`
}

type TopicReplicationUpdate struct {
	CopyAccessControlListsForTopics *bool `json:"copyAccessControlListsForTopics,omitempty"`

	CopyTopicConfigurations *bool `json:"copyTopicConfigurations,omitempty"`

	DetectAndCopyNewTopics *bool `json:"detectAndCopyNewTopics,omitempty"`
}

type Unauthenticated struct {
	Enabled *bool `json:"enabled,omitempty"`
}

type UnprocessedSCRAMSecret struct {
	ErrorCode *string `json:"errorCode,omitempty"`

	ErrorMessage *string `json:"errorMessage,omitempty"`

	SecretARN *string `json:"secretARN,omitempty"`
}

type UserIdentity struct {
	PrincipalID *string `json:"principalID,omitempty"`
}

type UserIdentityType string

type VPCConfig struct {
	SecurityGroupIDs []*string `json:"securityGroupIDs,omitempty"`

	SubnetIDs []*string `json:"subnetIDs,omitempty"`
}

type VPCConnection struct {
	Authentication *string `json:"authentication,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	TargetClusterARN *string `json:"targetClusterARN,omitempty"`

	VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"`

	VPCID *string `json:"vpcID,omitempty"`
}

type VPCConnectionInfo struct {
	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Owner *string `json:"owner,omitempty"`

	VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"`
}

type VPCConnectionInfoServerless struct {
	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Owner *string `json:"owner,omitempty"`

	VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"`
}

type VPCConnectionState string

type VPCConnectivity struct {
	ClientAuthentication *VPCConnectivityClientAuthentication `json:"clientAuthentication,omitempty"`
}

type VPCConnectivityClientAuthentication struct {
	SASL *VPCConnectivitySASL `json:"sasl,omitempty"`

	TLS *VPCConnectivityTLS `json:"tls,omitempty"`
}

type VPCConnectivityIAM struct {
	Enabled *bool `json:"enabled,omitempty"`
}

type VPCConnectivitySASL struct {
	IAM *VPCConnectivityIAM `json:"iam,omitempty"`

	SCRAM *VPCConnectivitySCRAM `json:"scram,omitempty"`
}

type VPCConnectivitySCRAM struct {
	Enabled *bool `json:"enabled,omitempty"`
}

type VPCConnectivityTLS struct {
	Enabled *bool `json:"enabled,omitempty"`
}

type ZookeeperNodeInfo struct {
	AttachedENIID *string `json:"attachedENIID,omitempty"`

	ClientVPCIPAddress *string `json:"clientVPCIPAddress,omitempty"`

	Endpoints []*string `json:"endpoints,omitempty"`

	ZookeeperVersion *string `json:"zookeeperVersion,omitempty"`
}