Kafka
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)