pulumi-azure-native-kotlin/com.pulumi.azurenative.iotoperationsmq.kotlin/KafkaConnectorArgs

KafkaConnectorArgs

data class KafkaConnectorArgs(val clientIdPrefix: Output<String>? = null, val extendedLocation: Output<ExtendedLocationPropertyArgs>? = null, val image: Output<ContainerImageArgs>? = null, val instances: Output<Int>? = null, val kafkaConnection: Output<KafkaRemoteBrokerConnectionSpecArgs>? = null, val kafkaConnectorName: Output<String>? = null, val localBrokerConnection: Output<LocalBrokerConnectionSpecArgs>? = null, val location: Output<String>? = null, val logLevel: Output<String>? = null, val mqName: Output<String>? = null, val nodeTolerations: Output<NodeTolerationsArgs>? = null, val resourceGroupName: Output<String>? = null, val tags: Output<Map<String, String>>? = null) : ConvertibleToJava<KafkaConnectorArgs>

MQ kafkaConnector resource Azure REST API version: 2023-10-04-preview.

Example Usage

KafkaConnector_CreateOrUpdate

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
    var kafkaConnector = new AzureNative.IoTOperationsMQ.KafkaConnector("kafkaConnector", new()
    {
        ClientIdPrefix = "yybbbeowkw",
        ExtendedLocation = new AzureNative.IoTOperationsMQ.Inputs.ExtendedLocationPropertyArgs
        {
            Name = "an",
            Type = "CustomLocation",
        },
        Image = new AzureNative.IoTOperationsMQ.Inputs.ContainerImageArgs
        {
            PullPolicy = "imfuzvqxgbdwliqnn",
            PullSecrets = "klnqimxqsrdwhcqldjvdtsrs",
            Repository = "m",
            Tag = "jygfdiamhhm",
        },
        Instances = 55252,
        KafkaConnection = new AzureNative.IoTOperationsMQ.Inputs.KafkaRemoteBrokerConnectionSpecArgs
        {
            Authentication = new AzureNative.IoTOperationsMQ.Inputs.KafkaRemoteBrokerAuthenticationPropertiesArgs
            {
                AuthType = new AzureNative.IoTOperationsMQ.Inputs.KafkaRemoteBrokerAuthenticationTypesArgs
                {
                    Sasl = new AzureNative.IoTOperationsMQ.Inputs.SaslRemoteBrokerBasicAuthenticationArgs
                    {
                        SaslType = "plain",
                        Token = new AzureNative.IoTOperationsMQ.Inputs.SaslRemoteBrokerBasicAuthenticationTokenArgs
                        {
                            KeyVault = new AzureNative.IoTOperationsMQ.Inputs.KafkaTokenKeyVaultPropertiesArgs
                            {
                                Username = "fb",
                                Vault = new AzureNative.IoTOperationsMQ.Inputs.KeyVaultConnectionPropertiesArgs
                                {
                                    Credentials = new AzureNative.IoTOperationsMQ.Inputs.KeyVaultCredentialsPropertiesArgs
                                    {
                                        ServicePrincipalLocalSecretName = "wuimjwpbhoglbsxxa",
                                    },
                                    DirectoryId = "eyjniptiykzcgbzok",
                                    Name = "lxmwfan",
                                },
                                VaultSecret = new AzureNative.IoTOperationsMQ.Inputs.KeyVaultSecretObjectArgs
                                {
                                    Name = "bmectskddmpjxnsogwooexj",
                                    Version = "unjfbf",
                                },
                            },
                            SecretName = "hxmqokubwldgjdtjv",
                        },
                    },
                    SystemAssignedManagedIdentity = new AzureNative.IoTOperationsMQ.Inputs.ManagedIdentityAuthenticationArgs
                    {
                        Audience = "kjderojhpehosgfcrxxbh",
                        ExtensionName = "cyckjqqzspleajbtkniwrfsqygjfhe",
                    },
                    X509 = new AzureNative.IoTOperationsMQ.Inputs.KafkaX509AuthenticationArgs
                    {
                        KeyVault = new AzureNative.IoTOperationsMQ.Inputs.KeyVaultCertificatePropertiesArgs
                        {
                            Vault = new AzureNative.IoTOperationsMQ.Inputs.KeyVaultConnectionPropertiesArgs
                            {
                                Credentials = new AzureNative.IoTOperationsMQ.Inputs.KeyVaultCredentialsPropertiesArgs
                                {
                                    ServicePrincipalLocalSecretName = "wuimjwpbhoglbsxxa",
                                },
                                DirectoryId = "eyjniptiykzcgbzok",
                                Name = "lxmwfan",
                            },
                            VaultCaChainSecret = new AzureNative.IoTOperationsMQ.Inputs.KeyVaultSecretObjectArgs
                            {
                                Name = "bmectskddmpjxnsogwooexj",
                                Version = "unjfbf",
                            },
                            VaultCert = new AzureNative.IoTOperationsMQ.Inputs.KeyVaultSecretObjectArgs
                            {
                                Name = "bmectskddmpjxnsogwooexj",
                                Version = "unjfbf",
                            },
                        },
                        SecretName = "jlrjvqyoygynlpsekfbvyrpu",
                    },
                },
                Enabled = true,
            },
            Endpoint = "odxpssuhjkbonjmbhbebfjcah",
            Tls = new AzureNative.IoTOperationsMQ.Inputs.KafkaRemoteBrokerConnectionTlsArgs
            {
                TlsEnabled = true,
                TrustedCaCertificateConfigMap = "kndjozglnxsgnzxq",
            },
        },
        KafkaConnectorName = "V5--OL8-R",
        LocalBrokerConnection = new AzureNative.IoTOperationsMQ.Inputs.LocalBrokerConnectionSpecArgs
        {
            Authentication = new AzureNative.IoTOperationsMQ.Inputs.LocalBrokerAuthenticationMethodsArgs
            {
                Kubernetes = new AzureNative.IoTOperationsMQ.Inputs.LocalBrokerKubernetesAuthenticationArgs
                {
                    SecretPath = "soukzfkouir",
                    ServiceAccountTokenName = "suwetviuhmhorhvsidlznnufe",
                },
            },
            Endpoint = "xc",
            Tls = new AzureNative.IoTOperationsMQ.Inputs.LocalBrokerConnectionTlsArgs
            {
                TlsEnabled = true,
                TrustedCaCertificateConfigMap = "rinkomfeznsfedbmllxlbmmhc",
            },
        },
        Location = "mpbupgmqssnb",
        LogLevel = "g",
        MqName = "s47Lj-S2S-Q-XY",
        NodeTolerations = new AzureNative.IoTOperationsMQ.Inputs.NodeTolerationsArgs
        {
            Effect = "eeswvciblqmmaeesjoflyvxqbz",
            Key = "wbrstdwxgm",
            Operator = "lbegegneekwnyodtzraarivtwhmzep",
            Value = "sfafsjdcezdmkwibxeluukxgl",
        },
        ResourceGroupName = "rgiotoperationsmq",
        Tags = null,
    });
});
Content copied to clipboard
package main
import (
	"github.com/pulumi/pulumi-azure-native-sdk/iotoperationsmq/v2"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperationsmq.NewKafkaConnector(ctx, "kafkaConnector", &iotoperationsmq.KafkaConnectorArgs{
ClientIdPrefix: pulumi.String("yybbbeowkw"),
ExtendedLocation: &iotoperationsmq.ExtendedLocationPropertyArgs{
Name: pulumi.String("an"),
Type: pulumi.String("CustomLocation"),
},
Image: &iotoperationsmq.ContainerImageArgs{
PullPolicy: pulumi.String("imfuzvqxgbdwliqnn"),
PullSecrets: pulumi.String("klnqimxqsrdwhcqldjvdtsrs"),
Repository: pulumi.String("m"),
Tag: pulumi.String("jygfdiamhhm"),
},
Instances: pulumi.Int(55252),
KafkaConnection: iotoperationsmq.KafkaRemoteBrokerConnectionSpecResponse{
Authentication: interface{}{
AuthType: interface{}{
Sasl: interface{}{
SaslType: pulumi.String("plain"),
Token: interface{}{
KeyVault: interface{}{
Username: pulumi.String("fb"),
Vault: interface{}{
Credentials: &iotoperationsmq.KeyVaultCredentialsPropertiesArgs{
ServicePrincipalLocalSecretName: pulumi.String("wuimjwpbhoglbsxxa"),
},
DirectoryId: pulumi.String("eyjniptiykzcgbzok"),
Name: pulumi.String("lxmwfan"),
},
VaultSecret: &iotoperationsmq.KeyVaultSecretObjectArgs{
Name: pulumi.String("bmectskddmpjxnsogwooexj"),
Version: pulumi.String("unjfbf"),
},
},
SecretName: pulumi.String("hxmqokubwldgjdtjv"),
},
},
SystemAssignedManagedIdentity: &iotoperationsmq.ManagedIdentityAuthenticationArgs{
Audience: pulumi.String("kjderojhpehosgfcrxxbh"),
ExtensionName: pulumi.String("cyckjqqzspleajbtkniwrfsqygjfhe"),
},
X509: interface{}{
KeyVault: interface{}{
Vault: interface{}{
Credentials: &iotoperationsmq.KeyVaultCredentialsPropertiesArgs{
ServicePrincipalLocalSecretName: pulumi.String("wuimjwpbhoglbsxxa"),
},
DirectoryId: pulumi.String("eyjniptiykzcgbzok"),
Name: pulumi.String("lxmwfan"),
},
VaultCaChainSecret: &iotoperationsmq.KeyVaultSecretObjectArgs{
Name: pulumi.String("bmectskddmpjxnsogwooexj"),
Version: pulumi.String("unjfbf"),
},
VaultCert: &iotoperationsmq.KeyVaultSecretObjectArgs{
Name: pulumi.String("bmectskddmpjxnsogwooexj"),
Version: pulumi.String("unjfbf"),
},
},
SecretName: pulumi.String("jlrjvqyoygynlpsekfbvyrpu"),
},
},
Enabled: pulumi.Bool(true),
},
Endpoint: pulumi.String("odxpssuhjkbonjmbhbebfjcah"),
Tls: &iotoperationsmq.KafkaRemoteBrokerConnectionTlsArgs{
TlsEnabled: pulumi.Bool(true),
TrustedCaCertificateConfigMap: pulumi.String("kndjozglnxsgnzxq"),
},
},
KafkaConnectorName: pulumi.String("V5--OL8-R"),
LocalBrokerConnection: iotoperationsmq.LocalBrokerConnectionSpecResponse{
Authentication: interface{}{
Kubernetes: &iotoperationsmq.LocalBrokerKubernetesAuthenticationArgs{
SecretPath: pulumi.String("soukzfkouir"),
ServiceAccountTokenName: pulumi.String("suwetviuhmhorhvsidlznnufe"),
},
},
Endpoint: pulumi.String("xc"),
Tls: &iotoperationsmq.LocalBrokerConnectionTlsArgs{
TlsEnabled: pulumi.Bool(true),
TrustedCaCertificateConfigMap: pulumi.String("rinkomfeznsfedbmllxlbmmhc"),
},
},
Location: pulumi.String("mpbupgmqssnb"),
LogLevel: pulumi.String("g"),
MqName: pulumi.String("s47Lj-S2S-Q-XY"),
NodeTolerations: &iotoperationsmq.NodeTolerationsArgs{
Effect: pulumi.String("eeswvciblqmmaeesjoflyvxqbz"),
Key: pulumi.String("wbrstdwxgm"),
Operator: pulumi.String("lbegegneekwnyodtzraarivtwhmzep"),
Value: pulumi.String("sfafsjdcezdmkwibxeluukxgl"),
},
ResourceGroupName: pulumi.String("rgiotoperationsmq"),
Tags: nil,
})
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.iotoperationsmq.KafkaConnector;
import com.pulumi.azurenative.iotoperationsmq.KafkaConnectorArgs;
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 kafkaConnector = new KafkaConnector("kafkaConnector", KafkaConnectorArgs.builder()
            .clientIdPrefix("yybbbeowkw")
            .extendedLocation(Map.ofEntries(
                Map.entry("name", "an"),
                Map.entry("type", "CustomLocation")
            ))
            .image(Map.ofEntries(
                Map.entry("pullPolicy", "imfuzvqxgbdwliqnn"),
                Map.entry("pullSecrets", "klnqimxqsrdwhcqldjvdtsrs"),
                Map.entry("repository", "m"),
                Map.entry("tag", "jygfdiamhhm")
            ))
            .instances(55252)
            .kafkaConnection(Map.ofEntries(
                Map.entry("authentication", Map.ofEntries(
                    Map.entry("authType", Map.ofEntries(
                        Map.entry("sasl", Map.ofEntries(
                            Map.entry("saslType", "plain"),
                            Map.entry("token", Map.ofEntries(
                                Map.entry("keyVault", Map.ofEntries(
                                    Map.entry("username", "fb"),
                                    Map.entry("vault", Map.ofEntries(
                                        Map.entry("credentials", Map.of("servicePrincipalLocalSecretName", "wuimjwpbhoglbsxxa")),
                                        Map.entry("directoryId", "eyjniptiykzcgbzok"),
                                        Map.entry("name", "lxmwfan")
                                    )),
                                    Map.entry("vaultSecret", Map.ofEntries(
                                        Map.entry("name", "bmectskddmpjxnsogwooexj"),
                                        Map.entry("version", "unjfbf")
                                    ))
                                )),
                                Map.entry("secretName", "hxmqokubwldgjdtjv")
                            ))
                        )),
                        Map.entry("systemAssignedManagedIdentity", Map.ofEntries(
                            Map.entry("audience", "kjderojhpehosgfcrxxbh"),
                            Map.entry("extensionName", "cyckjqqzspleajbtkniwrfsqygjfhe")
                        )),
                        Map.entry("x509", Map.ofEntries(
                            Map.entry("keyVault", Map.ofEntries(
                                Map.entry("vault", Map.ofEntries(
                                    Map.entry("credentials", Map.of("servicePrincipalLocalSecretName", "wuimjwpbhoglbsxxa")),
                                    Map.entry("directoryId", "eyjniptiykzcgbzok"),
                                    Map.entry("name", "lxmwfan")
                                )),
                                Map.entry("vaultCaChainSecret", Map.ofEntries(
                                    Map.entry("name", "bmectskddmpjxnsogwooexj"),
                                    Map.entry("version", "unjfbf")
                                )),
                                Map.entry("vaultCert", Map.ofEntries(
                                    Map.entry("name", "bmectskddmpjxnsogwooexj"),
                                    Map.entry("version", "unjfbf")
                                ))
                            )),
                            Map.entry("secretName", "jlrjvqyoygynlpsekfbvyrpu")
                        ))
                    )),
                    Map.entry("enabled", true)
                )),
                Map.entry("endpoint", "odxpssuhjkbonjmbhbebfjcah"),
                Map.entry("tls", Map.ofEntries(
                    Map.entry("tlsEnabled", true),
                    Map.entry("trustedCaCertificateConfigMap", "kndjozglnxsgnzxq")
                ))
            ))
            .kafkaConnectorName("V5--OL8-R")
            .localBrokerConnection(Map.ofEntries(
                Map.entry("authentication", Map.of("kubernetes", Map.ofEntries(
                    Map.entry("secretPath", "soukzfkouir"),
                    Map.entry("serviceAccountTokenName", "suwetviuhmhorhvsidlznnufe")
                ))),
                Map.entry("endpoint", "xc"),
                Map.entry("tls", Map.ofEntries(
                    Map.entry("tlsEnabled", true),
                    Map.entry("trustedCaCertificateConfigMap", "rinkomfeznsfedbmllxlbmmhc")
                ))
            ))
            .location("mpbupgmqssnb")
            .logLevel("g")
            .mqName("s47Lj-S2S-Q-XY")
            .nodeTolerations(Map.ofEntries(
                Map.entry("effect", "eeswvciblqmmaeesjoflyvxqbz"),
                Map.entry("key", "wbrstdwxgm"),
                Map.entry("operator", "lbegegneekwnyodtzraarivtwhmzep"),
                Map.entry("value", "sfafsjdcezdmkwibxeluukxgl")
            ))
            .resourceGroupName("rgiotoperationsmq")
            .tags()
            .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:iotoperationsmq:KafkaConnector acntmeqjezkawbphgyprhwv /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.IoTOperationsMQ/mq/{mqName}/kafkaConnector/{kafkaConnectorName}
Content copied to clipboard

Constructors

Link copied to clipboard
fun KafkaConnectorArgs(clientIdPrefix: Output<String>? = null, extendedLocation: Output<ExtendedLocationPropertyArgs>? = null, image: Output<ContainerImageArgs>? = null, instances: Output<Int>? = null, kafkaConnection: Output<KafkaRemoteBrokerConnectionSpecArgs>? = null, kafkaConnectorName: Output<String>? = null, localBrokerConnection: Output<LocalBrokerConnectionSpecArgs>? = null, location: Output<String>? = null, logLevel: Output<String>? = null, mqName: Output<String>? = null, nodeTolerations: Output<NodeTolerationsArgs>? = null, resourceGroupName: Output<String>? = null, tags: Output<Map<String, String>>? = null)

Functions

Link copied to clipboard
open override fun toJava(): KafkaConnectorArgs

Properties

Link copied to clipboard
val clientIdPrefix: Output<String>? = null

The client id prefix of the dynamically generated client ids.

Link copied to clipboard
val extendedLocation: Output<ExtendedLocationPropertyArgs>? = null

Extended Location

Link copied to clipboard
val image: Output<ContainerImageArgs>? = null

The details of KafkaConnector Docker Image.

Link copied to clipboard
val instances: Output<Int>? = null

The number of KafkaConnector pods to spin up.

Link copied to clipboard
val kafkaConnection: Output<KafkaRemoteBrokerConnectionSpecArgs>? = null

The details for connecting with Remote Kafka Broker.

Link copied to clipboard
val kafkaConnectorName: Output<String>? = null

Name of MQ kafkaConnector resource

Link copied to clipboard
val localBrokerConnection: Output<LocalBrokerConnectionSpecArgs>? = null

The details for connecting with Local Broker.

Link copied to clipboard
val location: Output<String>? = null

The geo-location where the resource lives

Link copied to clipboard
val logLevel: Output<String>? = null

The log level of the Bridge Connector instances.

Link copied to clipboard
val mqName: Output<String>? = null

Name of MQ resource

Link copied to clipboard
val nodeTolerations: Output<NodeTolerationsArgs>? = null

The Node Tolerations for the Bridge Connector pods.

Link copied to clipboard
val resourceGroupName: Output<String>? = null

The name of the resource group. The name is case insensitive.

Link copied to clipboard
val tags: Output<Map<String, String>>? = null

Resource tags.