pulumi-azure-native-kotlin/com.pulumi.azurenative.purview.kotlin/KafkaConfigurationArgs

KafkaConfigurationArgs

data class KafkaConfigurationArgs(val accountName: Output<String>? = null, val consumerGroup: Output<String>? = null, val credentials: Output<CredentialsArgs>? = null, val eventHubPartitionId: Output<String>? = null, val eventHubResourceId: Output<String>? = null, val eventHubType: Output<Either<String, EventHubType>>? = null, val eventStreamingState: Output<Either<String, EventStreamingState>>? = null, val eventStreamingType: Output<Either<String, EventStreamingType>>? = null, val kafkaConfigurationName: Output<String>? = null, val resourceGroupName: Output<String>? = null) : ConvertibleToJava<KafkaConfigurationArgs>

The configuration of the event streaming service resource attached to the Purview account for kafka notifications. Azure REST API version: 2021-12-01.

Example Usage

KafkaConfigurations_CreateOrUpdate

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
    var kafkaConfiguration = new AzureNative.Purview.KafkaConfiguration("kafkaConfiguration", new()
    {
        AccountName = "account1",
        ConsumerGroup = "consumerGroup",
        Credentials = new AzureNative.Purview.Inputs.CredentialsArgs
        {
            IdentityId = "/subscriptions/47e8596d-ee73-4eb2-b6b4-cc13c2b87ssd/resourceGroups/testRG/providers/Microsoft.ManagedIdentity/userAssignedIdentities/testId",
            Type = "UserAssigned",
        },
        EventHubPartitionId = "partitionId",
        EventHubResourceId = "/subscriptions/225be6fe-ec1c-4d51-a368-f69348d2e6c5/resourceGroups/testRG/providers/Microsoft.EventHub/namespaces/eventHubNameSpaceName",
        EventHubType = "Notification",
        EventStreamingState = "Enabled",
        EventStreamingType = "Azure",
        KafkaConfigurationName = "kafkaConfigName",
        ResourceGroupName = "rgpurview",
    });
});

package main
import (
	"github.com/pulumi/pulumi-azure-native-sdk/purview/v2"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := purview.NewKafkaConfiguration(ctx, "kafkaConfiguration", &purview.KafkaConfigurationArgs{
			AccountName:   pulumi.String("account1"),
			ConsumerGroup: pulumi.String("consumerGroup"),
			Credentials: &purview.CredentialsArgs{
				IdentityId: pulumi.String("/subscriptions/47e8596d-ee73-4eb2-b6b4-cc13c2b87ssd/resourceGroups/testRG/providers/Microsoft.ManagedIdentity/userAssignedIdentities/testId"),
				Type:       pulumi.String("UserAssigned"),
			},
			EventHubPartitionId:    pulumi.String("partitionId"),
			EventHubResourceId:     pulumi.String("/subscriptions/225be6fe-ec1c-4d51-a368-f69348d2e6c5/resourceGroups/testRG/providers/Microsoft.EventHub/namespaces/eventHubNameSpaceName"),
			EventHubType:           pulumi.String("Notification"),
			EventStreamingState:    pulumi.String("Enabled"),
			EventStreamingType:     pulumi.String("Azure"),
			KafkaConfigurationName: pulumi.String("kafkaConfigName"),
			ResourceGroupName:      pulumi.String("rgpurview"),
		})
		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.purview.KafkaConfiguration;
import com.pulumi.azurenative.purview.KafkaConfigurationArgs;
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 kafkaConfiguration = new KafkaConfiguration("kafkaConfiguration", KafkaConfigurationArgs.builder()
            .accountName("account1")
            .consumerGroup("consumerGroup")
            .credentials(Map.ofEntries(
                Map.entry("identityId", "/subscriptions/47e8596d-ee73-4eb2-b6b4-cc13c2b87ssd/resourceGroups/testRG/providers/Microsoft.ManagedIdentity/userAssignedIdentities/testId"),
                Map.entry("type", "UserAssigned")
            ))
            .eventHubPartitionId("partitionId")
            .eventHubResourceId("/subscriptions/225be6fe-ec1c-4d51-a368-f69348d2e6c5/resourceGroups/testRG/providers/Microsoft.EventHub/namespaces/eventHubNameSpaceName")
            .eventHubType("Notification")
            .eventStreamingState("Enabled")
            .eventStreamingType("Azure")
            .kafkaConfigurationName("kafkaConfigName")
            .resourceGroupName("rgpurview")
            .build());
    }
}

Import

An existing resource can be imported using its type token, name, and identifier, e.g.

$ pulumi import azure-native:purview:KafkaConfiguration kafkaConfigName /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Purview/accounts/{accountName}/kafkaConfigurations/{kafkaConfigurationName}

Constructors

KafkaConfigurationArgs

fun KafkaConfigurationArgs(accountName: Output<String>? = null, consumerGroup: Output<String>? = null, credentials: Output<CredentialsArgs>? = null, eventHubPartitionId: Output<String>? = null, eventHubResourceId: Output<String>? = null, eventHubType: Output<Either<String, EventHubType>>? = null, eventStreamingState: Output<Either<String, EventStreamingState>>? = null, eventStreamingType: Output<Either<String, EventStreamingType>>? = null, kafkaConfigurationName: Output<String>? = null, resourceGroupName: Output<String>? = null)