Connector

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
    var connector = new AzureNative.Confluent.Connector("connector", new()
    {
        ClusterId = "dlz-f3a90de",
        ConnectorBasicInfo = new AzureNative.Confluent.Inputs.ConnectorInfoBaseArgs
        {
            ConnectorClass = "AZUREBLOBSTORAGESINK",
            ConnectorName = "connector-1",
            ConnectorType = AzureNative.Confluent.ConnectorType.SINK,
        },
        ConnectorName = "connector-1",
        ConnectorServiceTypeInfo = new AzureNative.Confluent.Inputs.AzureBlobStorageSinkConnectorServiceInfoArgs
        {
            ConnectorServiceType = "AzureBlobStorageSinkConnector",
            StorageAccountKey = "*******",
            StorageAccountName = "stcfaccount-1",
            StorageContainerName = "continer-1",
        },
        EnvironmentId = "env-12132",
        OrganizationName = "myOrganization",
        PartnerConnectorInfo = new AzureNative.Confluent.Inputs.KafkaAzureBlobStorageSinkConnectorInfoArgs
        {
            ApiKey = "xxxxxxx",
            ApiSecret = "*******",
            AuthType = AzureNative.Confluent.AuthType.KAFKA_API_KEY,
            FlushSize = "1000",
            InputFormat = AzureNative.Confluent.DataFormatType.JSON,
            MaxTasks = "2",
            OutputFormat = AzureNative.Confluent.DataFormatType.JSON,
            PartnerConnectorType = "KafkaAzureBlobStorageSink",
            TimeInterval = "DAILY",
            Topics = new[]
            {
                "topic-1",
            },
            TopicsDir = "topicsDir",
        },
        ResourceGroupName = "myResourceGroup",
    });
});

package main
import (
	confluent "github.com/pulumi/pulumi-azure-native-sdk/confluent/v2"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := confluent.NewConnector(ctx, "connector", &confluent.ConnectorArgs{
			ClusterId: pulumi.String("dlz-f3a90de"),
			ConnectorBasicInfo: &confluent.ConnectorInfoBaseArgs{
				ConnectorClass: pulumi.String("AZUREBLOBSTORAGESINK"),
				ConnectorName:  pulumi.String("connector-1"),
				ConnectorType:  pulumi.String(confluent.ConnectorTypeSINK),
			},
			ConnectorName: pulumi.String("connector-1"),
			ConnectorServiceTypeInfo: &confluent.AzureBlobStorageSinkConnectorServiceInfoArgs{
				ConnectorServiceType: pulumi.String("AzureBlobStorageSinkConnector"),
				StorageAccountKey:    pulumi.String("*******"),
				StorageAccountName:   pulumi.String("stcfaccount-1"),
				StorageContainerName: pulumi.String("continer-1"),
			},
			EnvironmentId:    pulumi.String("env-12132"),
			OrganizationName: pulumi.String("myOrganization"),
			PartnerConnectorInfo: &confluent.KafkaAzureBlobStorageSinkConnectorInfoArgs{
				ApiKey:               pulumi.String("xxxxxxx"),
				ApiSecret:            pulumi.String("*******"),
				AuthType:             pulumi.String(confluent.AuthType_KAFKA_API_KEY),
				FlushSize:            pulumi.String("1000"),
				InputFormat:          pulumi.String(confluent.DataFormatTypeJSON),
				MaxTasks:             pulumi.String("2"),
				OutputFormat:         pulumi.String(confluent.DataFormatTypeJSON),
				PartnerConnectorType: pulumi.String("KafkaAzureBlobStorageSink"),
				TimeInterval:         pulumi.String("DAILY"),
				Topics: pulumi.StringArray{
					pulumi.String("topic-1"),
				},
				TopicsDir: pulumi.String("topicsDir"),
			},
			ResourceGroupName: pulumi.String("myResourceGroup"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.confluent.Connector;
import com.pulumi.azurenative.confluent.ConnectorArgs;
import com.pulumi.azurenative.confluent.inputs.ConnectorInfoBaseArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }
    public static void stack(Context ctx) {
        var connector = new Connector("connector", ConnectorArgs.builder()
            .clusterId("dlz-f3a90de")
            .connectorBasicInfo(ConnectorInfoBaseArgs.builder()
                .connectorClass("AZUREBLOBSTORAGESINK")
                .connectorName("connector-1")
                .connectorType("SINK")
                .build())
            .connectorName("connector-1")
            .connectorServiceTypeInfo(AzureBlobStorageSinkConnectorServiceInfoArgs.builder()
                .connectorServiceType("AzureBlobStorageSinkConnector")
                .storageAccountKey("*******")
                .storageAccountName("stcfaccount-1")
                .storageContainerName("continer-1")
                .build())
            .environmentId("env-12132")
            .organizationName("myOrganization")
            .partnerConnectorInfo(KafkaAzureBlobStorageSinkConnectorInfoArgs.builder()
                .apiKey("xxxxxxx")
                .apiSecret("*******")
                .authType("KAFKA_API_KEY")
                .flushSize("1000")
                .inputFormat("JSON")
                .maxTasks("2")
                .outputFormat("JSON")
                .partnerConnectorType("KafkaAzureBlobStorageSink")
                .timeInterval("DAILY")
                .topics("topic-1")
                .topicsDir("topicsDir")
                .build())
            .resourceGroupName("myResourceGroup")
            .build());
    }
}

$ pulumi import azure-native:confluent:Connector connector-1 /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Confluent/organizations/{organizationName}/environments/{environmentId}/clusters/{clusterId}/connectors/{connectorName}