KafkaConfiguration

class KafkaConfiguration : KotlinCustomResource

The configuration of the event streaming service resource attached to the Purview account for kafka notifications. Uses Azure REST API version 2021-12-01. Other available API versions: 2023-05-01-preview, 2024-04-01-preview.

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.CredentialsType.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.CredentialsTypeUserAssigned),
},
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}

Properties

Link copied to clipboard
val consumerGroup: Output<String>?

Consumer group for hook event hub.

Link copied to clipboard

Credentials to access event hub.

Link copied to clipboard

Optional partition Id for notification event hub. If not set, all partitions will be leveraged.

Link copied to clipboard
Link copied to clipboard
val eventHubType: Output<String>?

The event hub type.

Link copied to clipboard

The state of the event streaming service

Link copied to clipboard

The event streaming service type

Link copied to clipboard
val id: Output<String>
Link copied to clipboard
val name: Output<String>

Gets or sets the name.

Link copied to clipboard
val pulumiChildResources: Set<KotlinResource>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Metadata pertaining to creation and last modification of the resource.

Link copied to clipboard
val type: Output<String>

Gets or sets the type.

Link copied to clipboard
val urn: Output<String>