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. Uses Azure REST API version 2024-04-01-preview. In version 2.x of the Azure Native provider, it used API version 2021-12-01. Other available API versions: 2021-12-01, 2023-05-01-preview. These can be accessed by generating a local SDK package using the CLI command pulumi package add azure-native purview [ApiVersion]. See the ../../../version-guide/#accessing-any-api-version-via-local-packages for details.

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 = AzureNative.Purview.KafkaConfigurationIdentityType.UserAssigned,
        },
        EventHubPartitionId = "partitionId",
        EventHubResourceId = "/subscriptions/225be6fe-ec1c-4d51-a368-f69348d2e6c5/resourceGroups/testRG/providers/Microsoft.EventHub/namespaces/eventHubNameSpaceName",
        EventHubType = AzureNative.Purview.EventHubType.Notification,
        EventStreamingState = AzureNative.Purview.EventStreamingState.Enabled,
        EventStreamingType = AzureNative.Purview.EventStreamingType.Azure,
        KafkaConfigurationName = "kafkaConfigName",
        ResourceGroupName = "rgpurview",
    });
});

package main
import (
	purview "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(purview.KafkaConfigurationIdentityTypeUserAssigned),
			},
			EventHubPartitionId:    pulumi.String("partitionId"),
			EventHubResourceId:     pulumi.String("/subscriptions/225be6fe-ec1c-4d51-a368-f69348d2e6c5/resourceGroups/testRG/providers/Microsoft.EventHub/namespaces/eventHubNameSpaceName"),
			EventHubType:           pulumi.String(purview.EventHubTypeNotification),
			EventStreamingState:    pulumi.String(purview.EventStreamingStateEnabled),
			EventStreamingType:     pulumi.String(purview.EventStreamingTypeAzure),
			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 com.pulumi.azurenative.purview.inputs.CredentialsArgs;
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(CredentialsArgs.builder()
                .identityId("/subscriptions/47e8596d-ee73-4eb2-b6b4-cc13c2b87ssd/resourceGroups/testRG/providers/Microsoft.ManagedIdentity/userAssignedIdentities/testId")
                .type("UserAssigned")
                .build())
            .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

constructor(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)