KafkaAzureBlobStorageSinkConnectorInfoArgs

data class KafkaAzureBlobStorageSinkConnectorInfoArgs(val apiKey: Output<String>? = null, val apiSecret: Output<String>? = null, val authType: Output<Either<String, AuthType>>? = null, val flushSize: Output<String>? = 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 timeInterval: Output<String>? = null, val topics: Output<List<String>>? = null, val topicsDir: Output<String>? = null) : ConvertibleToJava<KafkaAzureBlobStorageSinkConnectorInfoArgs>

The partner connector type is KafkaAzureBlobStorageSink

Constructors

constructor(apiKey: Output<String>? = null, apiSecret: Output<String>? = null, authType: Output<Either<String, AuthType>>? = null, flushSize: Output<String>? = null, inputFormat: Output<Either<String, DataFormatType>>? = null, maxTasks: Output<String>? = null, outputFormat: Output<Either<String, DataFormatType>>? = null, partnerConnectorType: Output<String>, serviceAccountId: Output<String>? = null, timeInterval: Output<String>? = null, topics: Output<List<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 Key Secret

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

Kafka Auth Type

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

Flush size

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 'KafkaAzureBlobStorageSink'.

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

Kafka Service Account Id

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

Time Interval

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

Kafka topics list

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

Kafka topics directory

Functions

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