Kafka Configuration
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",
});
});
Content copied to clipboard
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
})
}
Content copied to clipboard
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());
}
}
Content copied to clipboard
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}
Content copied to clipboard
Properties
Link copied to clipboard
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
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
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Metadata pertaining to creation and last modification of the resource.