Ready to level-up your engineering skills? Join a Pulumi Workshop. Register Now

getKafkaConnector

# Kafka connector Data Source

The Kafka connector data source provides information about the existing Aiven Kafka connector.

Example Usage

using Pulumi;
using Aiven = Pulumi.Aiven;

class MyStack : Stack
{
    public MyStack()
    {
        var kafka_es_con1 = Output.Create(Aiven.GetKafkaConnector.InvokeAsync(new Aiven.GetKafkaConnectorArgs
        {
            Project = aiven_project.Kafka_con_project1.Project,
            ServiceName = aiven_service.Kafka_service1.Service_name,
            ConnectorName = "kafka-es-con1",
        }));
    }

}
package main

import (
    "github.com/pulumi/pulumi-aiven/sdk/v3/go/aiven"
    "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)

func main() {
    pulumi.Run(func(ctx *pulumi.Context) error {
        _, err := aiven.LookupKafkaConnector(ctx, &aiven.LookupKafkaConnectorArgs{
            Project:       aiven_project.Kafka - con - project1.Project,
            ServiceName:   aiven_service.Kafka - service1.Service_name,
            ConnectorName: "kafka-es-con1",
        }, nil)
        if err != nil {
            return err
        }
        return nil
    })
}
import pulumi
import pulumi_aiven as aiven

kafka_es_con1 = aiven.get_kafka_connector(project=aiven_project["kafka-con-project1"]["project"],
    service_name=aiven_service["kafka-service1"]["service_name"],
    connector_name="kafka-es-con1")
import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";

const kafka-es-con1 = aiven.getKafkaConnector({
    project: aiven_project["kafka-con-project1"].project,
    serviceName: aiven_service["kafka-service1"].service_name,
    connectorName: "kafka-es-con1",
});

Using getKafkaConnector

function getKafkaConnector(args: GetKafkaConnectorArgs, opts?: InvokeOptions): Promise<GetKafkaConnectorResult>
def get_kafka_connector(config: Optional[Mapping[str, str]] = None, connector_name: Optional[str] = None, plugin_author: Optional[str] = None, plugin_class: Optional[str] = None, plugin_doc_url: Optional[str] = None, plugin_title: Optional[str] = None, plugin_type: Optional[str] = None, plugin_version: Optional[str] = None, project: Optional[str] = None, service_name: Optional[str] = None, tasks: Optional[Sequence[GetKafkaConnectorTaskArgs]] = None, opts: Optional[InvokeOptions] = None) -> GetKafkaConnectorResult
func LookupKafkaConnector(ctx *Context, args *LookupKafkaConnectorArgs, opts ...InvokeOption) (*LookupKafkaConnectorResult, error)

Note: This function is named LookupKafkaConnector in the Go SDK.

public static class GetKafkaConnector {
    public static Task<GetKafkaConnectorResult> InvokeAsync(GetKafkaConnectorArgs args, InvokeOptions? opts = null)
}

The following arguments are supported:

ConnectorName string
Project string
ServiceName string
Config Dictionary<string, string>
PluginAuthor string

Kafka connector author.

PluginClass string

Kafka connector Java class.

PluginDocUrl string

Kafka connector documentation URL.

PluginTitle string

Kafka connector title.

PluginType string

Kafka connector type.

PluginVersion string

Kafka connector version.

Tasks List<GetKafkaConnectorTaskArgs>

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

ConnectorName string
Project string
ServiceName string
Config map[string]string
PluginAuthor string

Kafka connector author.

PluginClass string

Kafka connector Java class.

PluginDocUrl string

Kafka connector documentation URL.

PluginTitle string

Kafka connector title.

PluginType string

Kafka connector type.

PluginVersion string

Kafka connector version.

Tasks []GetKafkaConnectorTask

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

connectorName string
project string
serviceName string
config {[key: string]: string}
pluginAuthor string

Kafka connector author.

pluginClass string

Kafka connector Java class.

pluginDocUrl string

Kafka connector documentation URL.

pluginTitle string

Kafka connector title.

pluginType string

Kafka connector type.

pluginVersion string

Kafka connector version.

tasks GetKafkaConnectorTask[]

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

connector_name str
project str
service_name str
config Mapping[str, str]
plugin_author str

Kafka connector author.

plugin_class str

Kafka connector Java class.

plugin_doc_url str

Kafka connector documentation URL.

plugin_title str

Kafka connector title.

plugin_type str

Kafka connector type.

plugin_version str

Kafka connector version.

tasks Sequence[GetKafkaConnectorTaskArgs]

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

getKafkaConnector Result

The following output properties are available:

ConnectorName string
Id string

The provider-assigned unique ID for this managed resource.

PluginAuthor string

Kafka connector author.

PluginClass string

Kafka connector Java class.

PluginDocUrl string

Kafka connector documentation URL.

PluginTitle string

Kafka connector title.

PluginType string

Kafka connector type.

PluginVersion string

Kafka connector version.

Project string
ServiceName string
Tasks List<GetKafkaConnectorTask>

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

Config Dictionary<string, string>
ConnectorName string
Id string

The provider-assigned unique ID for this managed resource.

PluginAuthor string

Kafka connector author.

PluginClass string

Kafka connector Java class.

PluginDocUrl string

Kafka connector documentation URL.

PluginTitle string

Kafka connector title.

PluginType string

Kafka connector type.

PluginVersion string

Kafka connector version.

Project string
ServiceName string
Tasks []GetKafkaConnectorTask

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

Config map[string]string
connectorName string
id string

The provider-assigned unique ID for this managed resource.

pluginAuthor string

Kafka connector author.

pluginClass string

Kafka connector Java class.

pluginDocUrl string

Kafka connector documentation URL.

pluginTitle string

Kafka connector title.

pluginType string

Kafka connector type.

pluginVersion string

Kafka connector version.

project string
serviceName string
tasks GetKafkaConnectorTask[]

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

config {[key: string]: string}
connector_name str
id str

The provider-assigned unique ID for this managed resource.

plugin_author str

Kafka connector author.

plugin_class str

Kafka connector Java class.

plugin_doc_url str

Kafka connector documentation URL.

plugin_title str

Kafka connector title.

plugin_type str

Kafka connector type.

plugin_version str

Kafka connector version.

project str
service_name str
tasks Sequence[GetKafkaConnectorTask]

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

config Mapping[str, str]

Supporting Types

GetKafkaConnectorTask

Connector string
Task int

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

Connector string
Task int

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

connector string
task number

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

connector str
task int

List of tasks of a connector, each element contains connector (Related connector name) and task (Task id / number).

Package Details

Repository
https://github.com/pulumi/pulumi-aiven
License
Apache-2.0
Notes
This Pulumi package is based on the aiven Terraform Provider.