← All packages

Aiven

Pulumi Official

Package maintained by Pulumi

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

Source code

getKafka

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

Example Usage

using Pulumi;
using Aiven = Pulumi.Aiven;

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

}

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.LookupKafka(ctx, &GetKafkaArgs{
			Project:     data.Aiven_project.Pr1.Project,
			ServiceName: "my-kafka1",
		}, 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 kafka1 = Output.of(AivenFunctions.getKafka(GetKafkaArgs.builder()
            .project(data.aiven_project().pr1().project())
            .serviceName("my-kafka1")
            .build()));

    }
}

import pulumi
import pulumi_aiven as aiven

kafka1 = aiven.get_kafka(project=data["aiven_project"]["pr1"]["project"],
    service_name="my-kafka1")

import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";

const kafka1 = aiven.getKafka({
    project: data.aiven_project.pr1.project,
    serviceName: "my-kafka1",
});

variables:
  kafka1:
    Fn::Invoke:
      Function: aiven:getKafka
      Arguments:
        project: ${data.aiven_project.pr1.project}
        serviceName: my-kafka1

Using getKafka

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 getKafka(args: GetKafkaArgs, opts?: InvokeOptions): Promise<GetKafkaResult>
function getKafkaOutput(args: GetKafkaOutputArgs, opts?: InvokeOptions): Output<GetKafkaResult>

def get_kafka(project: Optional[str] = None,
              service_name: Optional[str] = None,
              opts: Optional[InvokeOptions] = None) -> GetKafkaResult
def get_kafka_output(project: Optional[pulumi.Input[str]] = None,
              service_name: Optional[pulumi.Input[str]] = None,
              opts: Optional[InvokeOptions] = None) -> Output[GetKafkaResult]

func LookupKafka(ctx *Context, args *LookupKafkaArgs, opts ...InvokeOption) (*LookupKafkaResult, error)
func LookupKafkaOutput(ctx *Context, args *LookupKafkaOutputArgs, opts ...InvokeOption) LookupKafkaResultOutput

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

public static class GetKafka 
{
    public static Task<GetKafkaResult> InvokeAsync(GetKafkaArgs args, InvokeOptions? opts = null)
    public static Output<GetKafkaResult> Invoke(GetKafkaInvokeArgs args, InvokeOptions? opts = null)
}

public static CompletableFuture<GetKafkaResult> getKafka(GetKafkaArgs args, InvokeOptions options)
// Output-based functions aren't available in Java yet

Fn::Invoke:
  Function: aiven:index/getKafka:getKafka
  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 str
service_name str

project String
serviceName String

getKafka Result

The following output properties are available:

CloudName string
Components List<GetKafkaComponent>
DefaultAcl bool
DiskSpace string
DiskSpaceCap string
DiskSpaceDefault string
DiskSpaceStep string
DiskSpaceUsed string
Id string: The provider-assigned unique ID for this managed resource.
KafkaUserConfigs List<GetKafkaKafkaUserConfig>
Kafkas List<GetKafkaKafka>
Karapace bool
MaintenanceWindowDow string
MaintenanceWindowTime string
Plan string
Project string
ProjectVpcId string
ServiceHost string
ServiceIntegrations List<GetKafkaServiceIntegration>
ServiceName string
ServicePassword string
ServicePort int
ServiceType string
ServiceUri string
ServiceUsername string
State string
StaticIps List<string>
Tags List<GetKafkaTag>
TerminationProtection bool

CloudName string
Components []GetKafkaComponent
DefaultAcl bool
DiskSpace string
DiskSpaceCap string
DiskSpaceDefault string
DiskSpaceStep string
DiskSpaceUsed string
Id string: The provider-assigned unique ID for this managed resource.
KafkaUserConfigs []GetKafkaKafkaUserConfig
Kafkas []GetKafkaKafka
Karapace bool
MaintenanceWindowDow string
MaintenanceWindowTime string
Plan string
Project string
ProjectVpcId string
ServiceHost string
ServiceIntegrations []GetKafkaServiceIntegration
ServiceName string
ServicePassword string
ServicePort int
ServiceType string
ServiceUri string
ServiceUsername string
State string
StaticIps []string
Tags []GetKafkaTag
TerminationProtection bool

cloudName String
components List<GetKafkaComponent>
defaultAcl Boolean
diskSpace String
diskSpaceCap String
diskSpaceDefault String
diskSpaceStep String
diskSpaceUsed String
id String: The provider-assigned unique ID for this managed resource.
kafkaUserConfigs List<GetKafkaKafkaUserConfig>
kafkas List<GetKafkaKafka>
karapace Boolean
maintenanceWindowDow String
maintenanceWindowTime String
plan String
project String
projectVpcId String
serviceHost String
serviceIntegrations List<GetKafkaServiceIntegration>
serviceName String
servicePassword String
servicePort Integer
serviceType String
serviceUri String
serviceUsername String
state String
staticIps List<String>
tags List<GetKafkaTag>
terminationProtection Boolean

cloudName string
components GetKafkaComponent[]
defaultAcl boolean
diskSpace string
diskSpaceCap string
diskSpaceDefault string
diskSpaceStep string
diskSpaceUsed string
id string: The provider-assigned unique ID for this managed resource.
kafkaUserConfigs GetKafkaKafkaUserConfig[]
kafkas GetKafkaKafka[]
karapace boolean
maintenanceWindowDow string
maintenanceWindowTime string
plan string
project string
projectVpcId string
serviceHost string
serviceIntegrations GetKafkaServiceIntegration[]
serviceName string
servicePassword string
servicePort number
serviceType string
serviceUri string
serviceUsername string
state string
staticIps string[]
tags GetKafkaTag[]
terminationProtection boolean

cloud_name str
components Sequence[GetKafkaComponent]
default_acl bool
disk_space str
disk_space_cap str
disk_space_default str
disk_space_step str
disk_space_used str
id str: The provider-assigned unique ID for this managed resource.
kafka_user_configs Sequence[GetKafkaKafkaUserConfig]
kafkas Sequence[GetKafkaKafka]
karapace bool
maintenance_window_dow str
maintenance_window_time str
plan str
project str
project_vpc_id str
service_host str
service_integrations Sequence[GetKafkaServiceIntegration]
service_name str
service_password str
service_port int
service_type str
service_uri str
service_username str
state str
static_ips Sequence[str]
tags Sequence[GetKafkaTag]
termination_protection bool

cloudName String
components List<Property Map>
defaultAcl Boolean
diskSpace String
diskSpaceCap String
diskSpaceDefault String
diskSpaceStep String
diskSpaceUsed String
id String: The provider-assigned unique ID for this managed resource.
kafkaUserConfigs List<Property Map>
kafkas List<Property Map>
karapace Boolean
maintenanceWindowDow String
maintenanceWindowTime String
plan String
project String
projectVpcId String
serviceHost String
serviceIntegrations List<Property Map>
serviceName String
servicePassword String
servicePort Number
serviceType String
serviceUri String
serviceUsername String
state String
staticIps List<String>
tags List<Property Map>
terminationProtection Boolean

Supporting Types

GetKafkaComponent

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 str
host str
kafka_authentication_method str
port int
route str
ssl bool
usage str

component String
host String
kafkaAuthenticationMethod String
port Number
route String
ssl Boolean
usage String

GetKafkaTag

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.

Aiven

getKafka

Example Usage

Using getKafka

getKafka Result

Supporting Types

GetKafkaComponent

GetKafkaKafka

GetKafkaKafkaUserConfig

GetKafkaKafkaUserConfigKafka

GetKafkaKafkaUserConfigKafkaAuthenticationMethods

GetKafkaKafkaUserConfigKafkaConnectConfig

GetKafkaKafkaUserConfigKafkaRestConfig

GetKafkaKafkaUserConfigPrivateAccess

GetKafkaKafkaUserConfigPrivatelinkAccess

GetKafkaKafkaUserConfigPublicAccess

GetKafkaKafkaUserConfigSchemaRegistryConfig

GetKafkaServiceIntegration

GetKafkaTag

Package Details

Contents