Aiven

Pulumi Official
Package maintained by Pulumi
v5.2.0 published on Wednesday, Jul 20, 2022 by Pulumi

getKafkaConnect

The Kafka Connect data source provides information about the existing Aiven Kafka Connect service.

Example Usage

using Pulumi;
using Aiven = Pulumi.Aiven;

class MyStack : Stack
{
    public MyStack()
    {
        var kc1 = Output.Create(Aiven.GetKafkaConnect.InvokeAsync(new Aiven.GetKafkaConnectArgs
        {
            Project = data.Aiven_project.Pr1.Project,
            ServiceName = "my-kc1",
        }));
    }

}
package main

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

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := aiven.LookupKafkaConnect(ctx, &GetKafkaConnectArgs{
			Project:     data.Aiven_project.Pr1.Project,
			ServiceName: "my-kc1",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}
package generated_program;

import java.util.*;
import java.io.*;
import java.nio.*;
import com.pulumi.*;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var kc1 = Output.of(AivenFunctions.getKafkaConnect(GetKafkaConnectArgs.builder()
            .project(data.aiven_project().pr1().project())
            .serviceName("my-kc1")
            .build()));

    }
}
import pulumi
import pulumi_aiven as aiven

kc1 = aiven.get_kafka_connect(project=data["aiven_project"]["pr1"]["project"],
    service_name="my-kc1")
import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";

const kc1 = aiven.getKafkaConnect({
    project: data.aiven_project.pr1.project,
    serviceName: "my-kc1",
});
variables:
  kc1:
    Fn::Invoke:
      Function: aiven:getKafkaConnect
      Arguments:
        project: ${data.aiven_project.pr1.project}
        serviceName: my-kc1

Using getKafkaConnect

Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

function getKafkaConnect(args: GetKafkaConnectArgs, opts?: InvokeOptions): Promise<GetKafkaConnectResult>
function getKafkaConnectOutput(args: GetKafkaConnectOutputArgs, opts?: InvokeOptions): Output<GetKafkaConnectResult>
def get_kafka_connect(project: Optional[str] = None,
                      service_name: Optional[str] = None,
                      opts: Optional[InvokeOptions] = None) -> GetKafkaConnectResult
def get_kafka_connect_output(project: Optional[pulumi.Input[str]] = None,
                      service_name: Optional[pulumi.Input[str]] = None,
                      opts: Optional[InvokeOptions] = None) -> Output[GetKafkaConnectResult]
func LookupKafkaConnect(ctx *Context, args *LookupKafkaConnectArgs, opts ...InvokeOption) (*LookupKafkaConnectResult, error)
func LookupKafkaConnectOutput(ctx *Context, args *LookupKafkaConnectOutputArgs, opts ...InvokeOption) LookupKafkaConnectResultOutput

> Note: This function is named LookupKafkaConnect in the Go SDK.

public static class GetKafkaConnect 
{
    public static Task<GetKafkaConnectResult> InvokeAsync(GetKafkaConnectArgs args, InvokeOptions? opts = null)
    public static Output<GetKafkaConnectResult> Invoke(GetKafkaConnectInvokeArgs args, InvokeOptions? opts = null)
}
public static CompletableFuture<GetKafkaConnectResult> getKafkaConnect(GetKafkaConnectArgs args, InvokeOptions options)
// Output-based functions aren't available in Java yet
Fn::Invoke:
  Function: aiven:index/getKafkaConnect:getKafkaConnect
  Arguments:
    # Arguments dictionary

The following arguments are supported:

Project string
ServiceName string
Project string
ServiceName string
project String
serviceName String
project string
serviceName string
project String
serviceName String

getKafkaConnect Result

The following output properties are available:

Supporting Types

GetKafkaConnectComponent

Component string
Host string
KafkaAuthenticationMethod string
Port int
Route string
Ssl bool
Usage string
Component string
Host string
KafkaAuthenticationMethod string
Port int
Route string
Ssl bool
Usage string
component String
host String
kafkaAuthenticationMethod String
port Integer
route String
ssl Boolean
usage String
component string
host string
kafkaAuthenticationMethod string
port number
route string
ssl boolean
usage string
component String
host String
kafkaAuthenticationMethod String
port Number
route String
ssl Boolean
usage String

GetKafkaConnectKafkaConnectUserConfig

GetKafkaConnectKafkaConnectUserConfigKafkaConnect

GetKafkaConnectKafkaConnectUserConfigPrivateAccess

GetKafkaConnectKafkaConnectUserConfigPrivatelinkAccess

Jolokia string
KafkaConnect string
Prometheus string
Jolokia string
KafkaConnect string
Prometheus string
jolokia String
kafkaConnect String
prometheus String
jolokia string
kafkaConnect string
prometheus string
jolokia String
kafkaConnect String
prometheus String

GetKafkaConnectKafkaConnectUserConfigPublicAccess

GetKafkaConnectServiceIntegration

GetKafkaConnectTag

Key string
Value string
Key string
Value string
key String
value String
key string
value string
key str
value str
key String
value String

Package Details

Repository
https://github.com/pulumi/pulumi-aiven
License
Apache-2.0
Notes

This Pulumi package is based on the aiven Terraform Provider.