KafkaAzureBlobStorageSourceConnectorInfoArgs

data class KafkaAzureBlobStorageSourceConnectorInfoArgs(val apiKey: Output<String>? = null, val apiSecret: Output<String>? = null, val authType: Output<Either<String, AuthType>>? = null, val inputFormat: Output<Either<String, DataFormatType>>? = null, val maxTasks: Output<String>? = null, val outputFormat: Output<Either<String, DataFormatType>>? = null, val partnerConnectorType: Output<String>, val serviceAccountId: Output<String>? = null, val topicRegex: Output<String>? = null, val topicsDir: Output<String>? = null) : ConvertibleToJava<KafkaAzureBlobStorageSourceConnectorInfoArgs>

The partner connector type is KafkaAzureBlobStorageSource

Constructors

constructor(apiKey: Output<String>? = null, apiSecret: Output<String>? = null, authType: Output<Either<String, AuthType>>? = null, inputFormat: Output<Either<String, DataFormatType>>? = null, maxTasks: Output<String>? = null, outputFormat: Output<Either<String, DataFormatType>>? = null, partnerConnectorType: Output<String>, serviceAccountId: Output<String>? = null, topicRegex: Output<String>? = null, topicsDir: Output<String>? = null)

Properties

Link copied to clipboard
val apiKey: Output<String>? = null

Kafka API Key

Link copied to clipboard
val apiSecret: Output<String>? = null

Kafka API Secret

Link copied to clipboard
val authType: Output<Either<String, AuthType>>? = null

Kafka Auth Type

Link copied to clipboard
val inputFormat: Output<Either<String, DataFormatType>>? = null

Kafka Input Data Format Type

Link copied to clipboard
val maxTasks: Output<String>? = null

Maximum Tasks

Link copied to clipboard
val outputFormat: Output<Either<String, DataFormatType>>? = null

Kafka Output Data Format Type

Link copied to clipboard

Partner Connector type. Expected value is 'KafkaAzureBlobStorageSource'.

Link copied to clipboard
val serviceAccountId: Output<String>? = null

Kafka Service Account Id

Link copied to clipboard
val topicRegex: Output<String>? = null

Kafka topics Regex pattern

Link copied to clipboard
val topicsDir: Output<String>? = null

Kafka topics directory

Functions

Link copied to clipboard
open override fun toJava(): KafkaAzureBlobStorageSourceConnectorInfoArgs