Managed Flink

1 resource kind. Generated from the operator's CRD schemas.

API Group: aws.konfig.io/v1alpha1

KinesisAnalyticsV2Application # CLOUD CONTROL · AWS::KinesisAnalyticsV2::Application

KinesisAnalyticsV2Application manages AWS::KinesisAnalyticsV2::Application through the AWS Cloud Control API.

kubectl get kinesisanalyticsv2applications · example on GitHub

Example

# KinesisAnalyticsV2Application — Managed Flink
# Full-options example generated from the CRD schema. Optional fields are
# included with sample values; delete what you don't need. Field reference:
# https://konfig-konector.io/docs/kinesisanalyticsv2.html#kinesisanalyticsv2application
apiVersion: aws.konfig.io/v1alpha1
kind: KinesisAnalyticsV2Application
metadata:
  name: example-kinesisanalyticsv2application
  namespace: default
spec:
  applicationConfiguration:
    applicationCodeConfiguration:
      codeContent:
        textContent: example
        zipFileContent: example
      codeContentType: PLAINTEXT
    applicationEncryptionConfiguration:
      keyType: AWS_OWNED_KEY
    applicationSnapshotConfiguration:
      snapshotsEnabled: true
    applicationSystemRollbackConfiguration:
      rollbackEnabled: true
    flinkApplicationConfiguration:
      checkpointConfiguration:
        checkpointInterval: 1
        checkpointingEnabled: true
        configurationType: DEFAULT
        minPauseBetweenCheckpoints: 1
      monitoringConfiguration:
        configurationType: DEFAULT
        logLevel: DEBUG
        metricsLevel: APPLICATION
      parallelismConfiguration:
        autoScalingEnabled: true
        configurationType: CUSTOM
        parallelism: 1
        parallelismPerKPU: 1
    sqlApplicationConfiguration:
      inputs:
      - inputSchema:
          recordColumns:
          - mapping: example
            name: example-kinesisanalyticsv2application
            sqlType: example
          recordEncoding: UTF-8
          recordFormat:
            recordFormatType: CSV
        namePrefix: example
    vpcConfigurations:
    - securityGroupIds:
      - example
      subnetIds:
      - example
    zeppelinApplicationConfiguration:
      customArtifactsConfiguration:
      - artifactType: DEPENDENCY_JAR
      deployAsApplicationConfiguration:
        s3ContentLocation:
          basePath: example
          bucketARN: arn:aws:iam::123456789012:role/example-role
      monitoringConfiguration:
        logLevel: DEBUG
  applicationDescription: Managed by konfig-konector
  applicationMaintenanceConfiguration:
    applicationMaintenanceWindowStartTime: '2026-01-01T00:00:00Z'
  applicationMode: INTERACTIVE
  applicationName: example-kinesisanalyticsv2application
  providerRef:
    name: example-kinesisanalyticsv2application
    region: us-east-1
  runConfiguration:
    applicationRestoreConfiguration:
      applicationRestoreType: SKIP_RESTORE_FROM_SNAPSHOT
      snapshotName: example-kinesisanalyticsv2application
    flinkRunConfiguration:
      allowNonRestoredState: false
  runtimeEnvironment: '2026-01-01T00:00:00Z'
  serviceExecutionRole: example
  tags:
  - key: example
    value: example

Spec

Field	Type	Required	Description
`applicationConfiguration`	object	—	Use this parameter to configure the application.
`applicationConfiguration.applicationCodeConfiguration`	object	—	The code location and type parameters for a Flink-based Kinesis Data Analytics application.
`applicationConfiguration.applicationCodeConfiguration.codeContent`	object	yes	The location and type of the application code.
`applicationConfiguration.applicationCodeConfiguration.codeContent.s3ContentLocation`	object	—	Information about the Amazon S3 bucket that contains the application code.
`applicationConfiguration.applicationCodeConfiguration.codeContent.s3ContentLocation.bucketARN`	string	yes	The Amazon Resource Name (ARN) for the S3 bucket containing the application code.
`applicationConfiguration.applicationCodeConfiguration.codeContent.s3ContentLocation.fileKey`	string	yes	The file key for the object containing the application code.
`applicationConfiguration.applicationCodeConfiguration.codeContent.s3ContentLocation.objectVersion`	string	—	The version of the object containing the application code.
`applicationConfiguration.applicationCodeConfiguration.codeContent.textContent`	string	—	The text-format code for a Flink-based Kinesis Data Analytics application.
`applicationConfiguration.applicationCodeConfiguration.codeContent.zipFileContent`	string	—	The zip-format code for a Flink-based Kinesis Data Analytics application.
`applicationConfiguration.applicationCodeConfiguration.codeContentType`	enum	yes	Specifies whether the code content is in text or zip format. Allowed: `PLAINTEXT, ZIPFILE`
`applicationConfiguration.applicationEncryptionConfiguration`	object	—	Describes whether customer managed key is enabled and key details for customer data encryption
`applicationConfiguration.applicationEncryptionConfiguration.keyId`	string	—	KMS KeyId.
`applicationConfiguration.applicationEncryptionConfiguration.keyType`	enum	yes	Specifies whether application data is encrypted using service key: AWS_OWNED_KEY or customer key: CUSTOMER_MANAGED_KEY Allowed: `AWS_OWNED_KEY, CUSTOMER_MANAGED_KEY`
`applicationConfiguration.applicationSnapshotConfiguration`	object	—	Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
`applicationConfiguration.applicationSnapshotConfiguration.snapshotsEnabled`	boolean	yes	Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
`applicationConfiguration.applicationSystemRollbackConfiguration`	object	—	Describes whether system initiated rollbacks are enabled for a Flink-based Kinesis Data Analytics application.
`applicationConfiguration.applicationSystemRollbackConfiguration.rollbackEnabled`	boolean	yes	Describes whether system initiated rollbacks are enabled for a Flink-based Kinesis Data Analytics application.
`applicationConfiguration.environmentProperties`	object	—	Describes execution properties for a Flink-based Kinesis Data Analytics application.
`applicationConfiguration.environmentProperties.propertyGroups`	array<object>	—	Describes the execution property groups.
`applicationConfiguration.environmentProperties.propertyGroups[].propertyGroupId`	string	—	Describes the key of an application execution property key-value pair.
`applicationConfiguration.environmentProperties.propertyGroups[].propertyMap`	map<string>	—	Describes the value of an application execution property key-value pair.
`applicationConfiguration.flinkApplicationConfiguration`	object	—	The creation and update parameters for a Flink-based Kinesis Data Analytics application.
`applicationConfiguration.flinkApplicationConfiguration.checkpointConfiguration`	object	—	Describes an application's checkpointing configuration.
`applicationConfiguration.flinkApplicationConfiguration.checkpointConfiguration.checkpointInterval`	integer	—	Describes the interval in milliseconds between checkpoint operations.
`applicationConfiguration.flinkApplicationConfiguration.checkpointConfiguration.checkpointingEnabled`	boolean	—	Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
`applicationConfiguration.flinkApplicationConfiguration.checkpointConfiguration.configurationType`	enum	yes	Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Allowed: `DEFAULT, CUSTOM`
`applicationConfiguration.flinkApplicationConfiguration.checkpointConfiguration.minPauseBetweenCheckpoints`	integer	—	Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
`applicationConfiguration.flinkApplicationConfiguration.monitoringConfiguration`	object	—	Describes configuration parameters for Amazon CloudWatch logging for an application.
`applicationConfiguration.flinkApplicationConfiguration.monitoringConfiguration.configurationType`	enum	yes	Describes whether to use the default CloudWatch logging configuration for an application. Allowed: `DEFAULT, CUSTOM`
`applicationConfiguration.flinkApplicationConfiguration.monitoringConfiguration.logLevel`	enum	—	Describes the verbosity of the CloudWatch Logs for an application. Allowed: `DEBUG, INFO, WARN, ERROR`
`applicationConfiguration.flinkApplicationConfiguration.monitoringConfiguration.metricsLevel`	enum	—	Describes the granularity of the CloudWatch Logs for an application. Allowed: `APPLICATION, OPERATOR, PARALLELISM, TASK`
`applicationConfiguration.flinkApplicationConfiguration.parallelismConfiguration`	object	—	Describes parameters for how an application executes multiple tasks simultaneously.
`applicationConfiguration.flinkApplicationConfiguration.parallelismConfiguration.autoScalingEnabled`	boolean	—	Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
`applicationConfiguration.flinkApplicationConfiguration.parallelismConfiguration.configurationType`	enum	yes	Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. Allowed: `CUSTOM, DEFAULT`
`applicationConfiguration.flinkApplicationConfiguration.parallelismConfiguration.parallelism`	integer	—	Describes the initial number of parallel tasks that a Java-based Kinesis Data Analytics application can perform.
`applicationConfiguration.flinkApplicationConfiguration.parallelismConfiguration.parallelismPerKPU`	integer	—	Describes the number of parallel tasks that a Java-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
`applicationConfiguration.sqlApplicationConfiguration`	object	—	The creation and update parameters for a SQL-based Kinesis Data Analytics application.
`applicationConfiguration.sqlApplicationConfiguration.inputs`	array<object>	—	The array of Input objects describing the input streams used by the application.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputParallelism`	object	—	Describes the number of in-application streams to create.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputParallelism.count`	integer	—	The number of in-application streams to create.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputProcessingConfiguration`	object	—	The InputProcessingConfiguration for the input.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputProcessingConfiguration.inputLambdaProcessor`	object	—	The InputLambdaProcessor that is used to preprocess the records in the stream before being processed by your application code.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputProcessingConfiguration.inputLambdaProcessor.resourceARN`	string	yes	The ARN of the Amazon Lambda function that operates on records in the stream.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputSchema`	object	yes	Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputSchema.recordColumns`	array<object>	yes	A list of `RecordColumn` objects.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputSchema.recordColumns[].mapping`	string	—	A reference to the data element in the streaming input or the reference data source.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputSchema.recordColumns[].name`	string	yes	The name of the column that is created in the in-application input stream or reference table.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputSchema.recordColumns[].sqlType`	string	yes	The type of column created in the in-application input stream or reference table.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputSchema.recordEncoding`	enum	—	Specifies the encoding of the records in the streaming source. Allowed: `UTF-8`
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputSchema.recordFormat`	object	yes	Specifies the format of the records on the streaming source.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputSchema.recordFormat.mappingParameters`	object	—	When you configure application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].inputSchema.recordFormat.recordFormatType`	enum	yes	The type of record format. Allowed: `CSV, JSON`
`applicationConfiguration.sqlApplicationConfiguration.inputs[].kinesisFirehoseInput`	object	—	If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].kinesisFirehoseInput.resourceARN`	string	yes	The Amazon Resource Name (ARN) of the delivery stream.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].kinesisStreamsInput`	object	—	If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
`applicationConfiguration.sqlApplicationConfiguration.inputs[].kinesisStreamsInput.resourceARN`	string	yes	The ARN of the input Kinesis data stream to read.
`applicationConfiguration.sqlApplicationConfiguration.inputs[].namePrefix`	string	yes	The name prefix to use when creating an in-application stream.
`applicationConfiguration.vpcConfigurations`	array<object>	—	The array of descriptions of VPC configurations available to the application.
`applicationConfiguration.vpcConfigurations[].securityGroupIds`	array<string>	yes	The array of SecurityGroup IDs used by the VPC configuration.
`applicationConfiguration.vpcConfigurations[].subnetIds`	array<string>	yes	The array of Subnet IDs used by the VPC configuration.
`applicationConfiguration.zeppelinApplicationConfiguration`	object	—	The configuration parameters for a Kinesis Data Analytics Studio notebook.
`applicationConfiguration.zeppelinApplicationConfiguration.catalogConfiguration`	object	—	The Amazon Glue Data Catalog that you use in queries in a Kinesis Data Analytics Studio notebook.
`applicationConfiguration.zeppelinApplicationConfiguration.catalogConfiguration.glueDataCatalogConfiguration`	object	—	The configuration parameters for the default Amazon Glue database.
`applicationConfiguration.zeppelinApplicationConfiguration.catalogConfiguration.glueDataCatalogConfiguration.databaseARN`	string	—	The Amazon Resource Name (ARN) of the database.
`applicationConfiguration.zeppelinApplicationConfiguration.customArtifactsConfiguration`	array<object>	—	A list of CustomArtifactConfiguration objects.
`applicationConfiguration.zeppelinApplicationConfiguration.customArtifactsConfiguration[].artifactType`	enum	yes	Set this to either `UDF` or `DEPENDENCY_JAR`. Allowed: `DEPENDENCY_JAR, UDF`
`applicationConfiguration.zeppelinApplicationConfiguration.customArtifactsConfiguration[].mavenReference`	object	—	The parameters required to fully specify a Maven reference.
`applicationConfiguration.zeppelinApplicationConfiguration.customArtifactsConfiguration[].mavenReference.artifactId`	string	yes	The artifact ID of the Maven reference.
`applicationConfiguration.zeppelinApplicationConfiguration.customArtifactsConfiguration[].mavenReference.groupId`	string	yes	The group ID of the Maven reference.
`applicationConfiguration.zeppelinApplicationConfiguration.customArtifactsConfiguration[].mavenReference.version`	string	yes	The version of the Maven reference.
`applicationConfiguration.zeppelinApplicationConfiguration.customArtifactsConfiguration[].s3ContentLocation`	object	—	The location of the custom artifacts.
`applicationConfiguration.zeppelinApplicationConfiguration.customArtifactsConfiguration[].s3ContentLocation.bucketARN`	string	yes	The Amazon Resource Name (ARN) for the S3 bucket containing the application code.
`applicationConfiguration.zeppelinApplicationConfiguration.customArtifactsConfiguration[].s3ContentLocation.fileKey`	string	yes	The file key for the object containing the application code.
`applicationConfiguration.zeppelinApplicationConfiguration.customArtifactsConfiguration[].s3ContentLocation.objectVersion`	string	—	The version of the object containing the application code.
`applicationConfiguration.zeppelinApplicationConfiguration.deployAsApplicationConfiguration`	object	—	The information required to deploy a Kinesis Data Analytics Studio notebook as an application with durable state.
`applicationConfiguration.zeppelinApplicationConfiguration.deployAsApplicationConfiguration.s3ContentLocation`	object	yes	The description of an Amazon S3 object that contains the Amazon Data Analytics application, including the Amazon Resource Name (ARN) of the S3 bucket, the name of the Amazon S3 object that contains the data, and the version number of the Amazon S3 object that contains the data.
`applicationConfiguration.zeppelinApplicationConfiguration.deployAsApplicationConfiguration.s3ContentLocation.basePath`	string	—	The base path for the S3 bucket.
`applicationConfiguration.zeppelinApplicationConfiguration.deployAsApplicationConfiguration.s3ContentLocation.bucketARN`	string	yes	The Amazon Resource Name (ARN) of the S3 bucket.
`applicationConfiguration.zeppelinApplicationConfiguration.monitoringConfiguration`	object	—	The monitoring configuration of a Kinesis Data Analytics Studio notebook.
`applicationConfiguration.zeppelinApplicationConfiguration.monitoringConfiguration.logLevel`	enum	—	The verbosity of the CloudWatch Logs for an application. Allowed: `DEBUG, INFO, WARN, ERROR`
`applicationDescription`	string	—	The description of the application.
`applicationMaintenanceConfiguration`	object	—	Used to configure start of maintenance window.
`applicationMaintenanceConfiguration.applicationMaintenanceWindowStartTime`	string	yes	The start time for the maintenance window.
`applicationMode`	enum	—	To create a Kinesis Data Analytics Studio notebook, you must set the mode to `INTERACTIVE`. Allowed: `INTERACTIVE, STREAMING`
`applicationName`	string	—	The name of the application.
`providerRef`	object	—	ProviderRef selects the AWSProvider (account/region) this resource is reconciled against.
`providerRef.name`	string	yes	Name of a cluster-scoped AWSProvider.
`providerRef.region`	string	—	Region overrides the provider's region for this resource only.
`runConfiguration`	object	—	Specifies run configuration (start parameters) of a Kinesis Data Analytics application.
`runConfiguration.applicationRestoreConfiguration`	object	—	Describes the restore behavior of a restarting application.
`runConfiguration.applicationRestoreConfiguration.applicationRestoreType`	enum	yes	Specifies how the application should be restored. Allowed: `SKIP_RESTORE_FROM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, RESTORE_FROM_CUSTOM_SNAPSHOT`
`runConfiguration.applicationRestoreConfiguration.snapshotName`	string	—	The identifier of an existing snapshot of application state to use to restart an application.
`runConfiguration.flinkRunConfiguration`	object	—	Describes the starting parameters for a Flink-based Kinesis Data Analytics application.
`runConfiguration.flinkRunConfiguration.allowNonRestoredState`	boolean	—	When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program.
`runtimeEnvironment`	string	yes	The runtime environment for the application.
`serviceExecutionRole`	string	yes	Specifies the IAM role that the application uses to access external resources.
`tags`	array<object>	—	A list of one or more tags to assign to the application.
`tags[].key`	string	yes
`tags[].value`	string	yes

Status

Field	Type	Required	Description
`attempt`	integer	—	Attempt counts failed create/delete requests; it salts the Cloud Control idempotency token so a retry is not served the cached failure.
`awsProvider`	object	—	AWSProvider confirms the account and region this resource was reconciled against.
`awsProvider.accountId`	string	—	AccountID the resource lives in.
`awsProvider.name`	string	—	Name of the AWSProvider used; empty when the operator's own credentials were used.
`awsProvider.region`	string	—	Region the resource lives in (empty for global services).
`conditions`	array<object>	—	Conditions describe the current state of the resource.
`conditions[].lastTransitionTime`	string	yes	lastTransitionTime is the last time the condition transitioned from one status to another.
`conditions[].message`	string	yes	message is a human readable message indicating details about the transition.
`conditions[].observedGeneration`	integer	—	observedGeneration represents the .metadata.generation that the condition was set based upon.
`conditions[].reason`	string	yes	reason contains a programmatic identifier indicating the reason for the condition's last transition.
`conditions[].status`	enum	yes	status of the condition, one of True, False, Unknown. Allowed: `True, False, Unknown`
`conditions[].type`	string	yes	type of condition in CamelCase or in foo.example.com/CamelCase.
`identifier`	string	—	Identifier is the Cloud Control primary identifier of the resource.
`lastSyncTime`	string	—
`observedGeneration`	integer	—
`operation`	string	—	Operation is the in-flight operation (CREATE, UPDATE, DELETE).
`operationStatus`	string	—	OperationStatus is the last reported operation status.
`requestToken`	string	—	RequestToken tracks an in-flight asynchronous operation.