aiven.getServiceIntegration (v5)

Aiven v5.6.0 (5.x), Mar 9 26

Viewing docs for Aiven v5.6.0 (Older version)
published on Monday, Mar 9, 2026 by Pulumi

Go to latest version

Schema (JSON)

pulumi/pulumi-aiven

Viewing docs for Aiven v5.6.0 (Older version)
published on Monday, Mar 9, 2026 by Pulumi

Go to latest version

Schema (JSON)

pulumi/pulumi-aiven

Service Integration defines an integration between two Aiven services or between Aiven service and an external integration endpoint. Integration could be for example sending metrics from Kafka service to an InfluxDB service, getting metrics from an InfluxDB service to a Grafana service to show dashboards, sending logs from any service to Elasticsearch, etc.

Example Usage

using System.Collections.Generic;
using Pulumi;
using Aiven = Pulumi.Aiven;

return await Deployment.RunAsync(() => 
{
    var myintegration = Aiven.GetServiceIntegration.Invoke(new()
    {
        Project = aiven_project.Myproject.Project,
        DestinationServiceName = "<DESTINATION_SERVICE_NAME>",
        IntegrationType = "datadog",
        SourceServiceName = "<SOURCE_SERVICE_NAME>",
    });

});

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.LookupServiceIntegration(ctx, &aiven.LookupServiceIntegrationArgs{
			Project:                aiven_project.Myproject.Project,
			DestinationServiceName: "<DESTINATION_SERVICE_NAME>",
			IntegrationType:        "datadog",
			SourceServiceName:      "<SOURCE_SERVICE_NAME>",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aiven.AivenFunctions;
import com.pulumi.aiven.inputs.GetServiceIntegrationArgs;
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) {
        final var myintegration = AivenFunctions.getServiceIntegration(GetServiceIntegrationArgs.builder()
            .project(aiven_project.myproject().project())
            .destinationServiceName("<DESTINATION_SERVICE_NAME>")
            .integrationType("datadog")
            .sourceServiceName("<SOURCE_SERVICE_NAME>")
            .build());

    }
}

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

const myintegration = aiven.getServiceIntegration({
    project: aiven_project.myproject.project,
    destinationServiceName: "<DESTINATION_SERVICE_NAME>",
    integrationType: "datadog",
    sourceServiceName: "<SOURCE_SERVICE_NAME>",
});

import pulumi
import pulumi_aiven as aiven

myintegration = aiven.get_service_integration(project=aiven_project["myproject"]["project"],
    destination_service_name="<DESTINATION_SERVICE_NAME>",
    integration_type="datadog",
    source_service_name="<SOURCE_SERVICE_NAME>")

variables:
  myintegration:
    fn::invoke:
      Function: aiven:getServiceIntegration
      Arguments:
        project: ${aiven_project.myproject.project}
        destinationServiceName: <DESTINATION_SERVICE_NAME>
        integrationType: datadog
        sourceServiceName: <SOURCE_SERVICE_NAME>

Using getServiceIntegration

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 getServiceIntegration(args: GetServiceIntegrationArgs, opts?: InvokeOptions): Promise<GetServiceIntegrationResult>
function getServiceIntegrationOutput(args: GetServiceIntegrationOutputArgs, opts?: InvokeOptions): Output<GetServiceIntegrationResult>

def get_service_integration(destination_service_name: Optional[str] = None,
                            integration_type: Optional[str] = None,
                            project: Optional[str] = None,
                            source_service_name: Optional[str] = None,
                            opts: Optional[InvokeOptions] = None) -> GetServiceIntegrationResult
def get_service_integration_output(destination_service_name: Optional[pulumi.Input[str]] = None,
                            integration_type: Optional[pulumi.Input[str]] = None,
                            project: Optional[pulumi.Input[str]] = None,
                            source_service_name: Optional[pulumi.Input[str]] = None,
                            opts: Optional[InvokeOptions] = None) -> Output[GetServiceIntegrationResult]

func LookupServiceIntegration(ctx *Context, args *LookupServiceIntegrationArgs, opts ...InvokeOption) (*LookupServiceIntegrationResult, error)
func LookupServiceIntegrationOutput(ctx *Context, args *LookupServiceIntegrationOutputArgs, opts ...InvokeOption) LookupServiceIntegrationResultOutput

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

public static class GetServiceIntegration 
{
    public static Task<GetServiceIntegrationResult> InvokeAsync(GetServiceIntegrationArgs args, InvokeOptions? opts = null)
    public static Output<GetServiceIntegrationResult> Invoke(GetServiceIntegrationInvokeArgs args, InvokeOptions? opts = null)
}

public static CompletableFuture<GetServiceIntegrationResult> getServiceIntegration(GetServiceIntegrationArgs args, InvokeOptions options)
public static Output<GetServiceIntegrationResult> getServiceIntegration(GetServiceIntegrationArgs args, InvokeOptions options)

fn::invoke:
  function: aiven:index/getServiceIntegration:getServiceIntegration
  arguments:
    # arguments dictionary

The following arguments are supported:

DestinationServiceName string: Destination service for the integration (if any)
IntegrationType string: Type of the service integration
Project string: Project the integration belongs to
SourceServiceName string: Source service for the integration (if any)

DestinationServiceName string: Destination service for the integration (if any)
IntegrationType string: Type of the service integration
Project string: Project the integration belongs to
SourceServiceName string: Source service for the integration (if any)

destinationServiceName String: Destination service for the integration (if any)
integrationType String: Type of the service integration
project String: Project the integration belongs to
sourceServiceName String: Source service for the integration (if any)

destinationServiceName string: Destination service for the integration (if any)
integrationType string: Type of the service integration
project string: Project the integration belongs to
sourceServiceName string: Source service for the integration (if any)

destination_service_name str: Destination service for the integration (if any)
integration_type str: Type of the service integration
project str: Project the integration belongs to
source_service_name str: Source service for the integration (if any)

destinationServiceName String: Destination service for the integration (if any)
integrationType String: Type of the service integration
project String: Project the integration belongs to
sourceServiceName String: Source service for the integration (if any)

getServiceIntegration Result

The following output properties are available:

ClickhouseKafkaUserConfigs List<GetServiceIntegrationClickhouseKafkaUserConfig>: ClickhouseKafka user configurable settings
ClickhousePostgresqlUserConfigs List<GetServiceIntegrationClickhousePostgresqlUserConfig>: ClickhousePostgresql user configurable settings
DatadogUserConfigs List<GetServiceIntegrationDatadogUserConfig>: Datadog user configurable settings
DestinationEndpointId string: Destination endpoint for the integration (if any)
DestinationServiceName string: Destination service for the integration (if any)
ExternalAwsCloudwatchMetricsUserConfigs List<GetServiceIntegrationExternalAwsCloudwatchMetricsUserConfig>: ExternalAwsCloudwatchMetrics user configurable settings
Id string: The provider-assigned unique ID for this managed resource.
IntegrationId string: Service Integration Id at aiven
IntegrationType string: Type of the service integration
KafkaConnectUserConfigs List<GetServiceIntegrationKafkaConnectUserConfig>: KafkaConnect user configurable settings
KafkaLogsUserConfigs List<GetServiceIntegrationKafkaLogsUserConfig>: KafkaLogs user configurable settings
KafkaMirrormakerUserConfigs List<GetServiceIntegrationKafkaMirrormakerUserConfig>: KafkaMirrormaker user configurable settings
LogsUserConfigs List<GetServiceIntegrationLogsUserConfig>: Logs user configurable settings
MetricsUserConfigs List<GetServiceIntegrationMetricsUserConfig>: Metrics user configurable settings
MirrormakerUserConfigs List<GetServiceIntegrationMirrormakerUserConfig>: Mirrormaker user configurable settings
Project string: Project the integration belongs to
SourceEndpointId string: Source endpoint for the integration (if any)
SourceServiceName string: Source service for the integration (if any)

ClickhouseKafkaUserConfigs []GetServiceIntegrationClickhouseKafkaUserConfig: ClickhouseKafka user configurable settings
ClickhousePostgresqlUserConfigs []GetServiceIntegrationClickhousePostgresqlUserConfig: ClickhousePostgresql user configurable settings
DatadogUserConfigs []GetServiceIntegrationDatadogUserConfig: Datadog user configurable settings
DestinationEndpointId string: Destination endpoint for the integration (if any)
DestinationServiceName string: Destination service for the integration (if any)
ExternalAwsCloudwatchMetricsUserConfigs []GetServiceIntegrationExternalAwsCloudwatchMetricsUserConfig: ExternalAwsCloudwatchMetrics user configurable settings
Id string: The provider-assigned unique ID for this managed resource.
IntegrationId string: Service Integration Id at aiven
IntegrationType string: Type of the service integration
KafkaConnectUserConfigs []GetServiceIntegrationKafkaConnectUserConfig: KafkaConnect user configurable settings
KafkaLogsUserConfigs []GetServiceIntegrationKafkaLogsUserConfig: KafkaLogs user configurable settings
KafkaMirrormakerUserConfigs []GetServiceIntegrationKafkaMirrormakerUserConfig: KafkaMirrormaker user configurable settings
LogsUserConfigs []GetServiceIntegrationLogsUserConfig: Logs user configurable settings
MetricsUserConfigs []GetServiceIntegrationMetricsUserConfig: Metrics user configurable settings
MirrormakerUserConfigs []GetServiceIntegrationMirrormakerUserConfig: Mirrormaker user configurable settings
Project string: Project the integration belongs to
SourceEndpointId string: Source endpoint for the integration (if any)
SourceServiceName string: Source service for the integration (if any)

clickhouseKafkaUserConfigs List<GetServiceIntegrationClickhouseKafkaUserConfig>: ClickhouseKafka user configurable settings
clickhousePostgresqlUserConfigs List<GetServiceIntegrationClickhousePostgresqlUserConfig>: ClickhousePostgresql user configurable settings
datadogUserConfigs List<GetServiceIntegrationDatadogUserConfig>: Datadog user configurable settings
destinationEndpointId String: Destination endpoint for the integration (if any)
destinationServiceName String: Destination service for the integration (if any)
externalAwsCloudwatchMetricsUserConfigs List<GetServiceIntegrationExternalAwsCloudwatchMetricsUserConfig>: ExternalAwsCloudwatchMetrics user configurable settings
id String: The provider-assigned unique ID for this managed resource.
integrationId String: Service Integration Id at aiven
integrationType String: Type of the service integration
kafkaConnectUserConfigs List<GetServiceIntegrationKafkaConnectUserConfig>: KafkaConnect user configurable settings
kafkaLogsUserConfigs List<GetServiceIntegrationKafkaLogsUserConfig>: KafkaLogs user configurable settings
kafkaMirrormakerUserConfigs List<GetServiceIntegrationKafkaMirrormakerUserConfig>: KafkaMirrormaker user configurable settings
logsUserConfigs List<GetServiceIntegrationLogsUserConfig>: Logs user configurable settings
metricsUserConfigs List<GetServiceIntegrationMetricsUserConfig>: Metrics user configurable settings
mirrormakerUserConfigs List<GetServiceIntegrationMirrormakerUserConfig>: Mirrormaker user configurable settings
project String: Project the integration belongs to
sourceEndpointId String: Source endpoint for the integration (if any)
sourceServiceName String: Source service for the integration (if any)

clickhouseKafkaUserConfigs GetServiceIntegrationClickhouseKafkaUserConfig[]: ClickhouseKafka user configurable settings
clickhousePostgresqlUserConfigs GetServiceIntegrationClickhousePostgresqlUserConfig[]: ClickhousePostgresql user configurable settings
datadogUserConfigs GetServiceIntegrationDatadogUserConfig[]: Datadog user configurable settings
destinationEndpointId string: Destination endpoint for the integration (if any)
destinationServiceName string: Destination service for the integration (if any)
externalAwsCloudwatchMetricsUserConfigs GetServiceIntegrationExternalAwsCloudwatchMetricsUserConfig[]: ExternalAwsCloudwatchMetrics user configurable settings
id string: The provider-assigned unique ID for this managed resource.
integrationId string: Service Integration Id at aiven
integrationType string: Type of the service integration
kafkaConnectUserConfigs GetServiceIntegrationKafkaConnectUserConfig[]: KafkaConnect user configurable settings
kafkaLogsUserConfigs GetServiceIntegrationKafkaLogsUserConfig[]: KafkaLogs user configurable settings
kafkaMirrormakerUserConfigs GetServiceIntegrationKafkaMirrormakerUserConfig[]: KafkaMirrormaker user configurable settings
logsUserConfigs GetServiceIntegrationLogsUserConfig[]: Logs user configurable settings
metricsUserConfigs GetServiceIntegrationMetricsUserConfig[]: Metrics user configurable settings
mirrormakerUserConfigs GetServiceIntegrationMirrormakerUserConfig[]: Mirrormaker user configurable settings
project string: Project the integration belongs to
sourceEndpointId string: Source endpoint for the integration (if any)
sourceServiceName string: Source service for the integration (if any)

clickhouse_kafka_user_configs Sequence[GetServiceIntegrationClickhouseKafkaUserConfig]: ClickhouseKafka user configurable settings
clickhouse_postgresql_user_configs Sequence[GetServiceIntegrationClickhousePostgresqlUserConfig]: ClickhousePostgresql user configurable settings
datadog_user_configs Sequence[GetServiceIntegrationDatadogUserConfig]: Datadog user configurable settings
destination_endpoint_id str: Destination endpoint for the integration (if any)
destination_service_name str: Destination service for the integration (if any)
external_aws_cloudwatch_metrics_user_configs Sequence[GetServiceIntegrationExternalAwsCloudwatchMetricsUserConfig]: ExternalAwsCloudwatchMetrics user configurable settings
id str: The provider-assigned unique ID for this managed resource.
integration_id str: Service Integration Id at aiven
integration_type str: Type of the service integration
kafka_connect_user_configs Sequence[GetServiceIntegrationKafkaConnectUserConfig]: KafkaConnect user configurable settings
kafka_logs_user_configs Sequence[GetServiceIntegrationKafkaLogsUserConfig]: KafkaLogs user configurable settings
kafka_mirrormaker_user_configs Sequence[GetServiceIntegrationKafkaMirrormakerUserConfig]: KafkaMirrormaker user configurable settings
logs_user_configs Sequence[GetServiceIntegrationLogsUserConfig]: Logs user configurable settings
metrics_user_configs Sequence[GetServiceIntegrationMetricsUserConfig]: Metrics user configurable settings
mirrormaker_user_configs Sequence[GetServiceIntegrationMirrormakerUserConfig]: Mirrormaker user configurable settings
project str: Project the integration belongs to
source_endpoint_id str: Source endpoint for the integration (if any)
source_service_name str: Source service for the integration (if any)

clickhouseKafkaUserConfigs List<Property Map>: ClickhouseKafka user configurable settings
clickhousePostgresqlUserConfigs List<Property Map>: ClickhousePostgresql user configurable settings
datadogUserConfigs List<Property Map>: Datadog user configurable settings
destinationEndpointId String: Destination endpoint for the integration (if any)
destinationServiceName String: Destination service for the integration (if any)
externalAwsCloudwatchMetricsUserConfigs List<Property Map>: ExternalAwsCloudwatchMetrics user configurable settings
id String: The provider-assigned unique ID for this managed resource.
integrationId String: Service Integration Id at aiven
integrationType String: Type of the service integration
kafkaConnectUserConfigs List<Property Map>: KafkaConnect user configurable settings
kafkaLogsUserConfigs List<Property Map>: KafkaLogs user configurable settings
kafkaMirrormakerUserConfigs List<Property Map>: KafkaMirrormaker user configurable settings
logsUserConfigs List<Property Map>: Logs user configurable settings
metricsUserConfigs List<Property Map>: Metrics user configurable settings
mirrormakerUserConfigs List<Property Map>: Mirrormaker user configurable settings
project String: Project the integration belongs to
sourceEndpointId String: Source endpoint for the integration (if any)
sourceServiceName String: Source service for the integration (if any)