Docs Home Pulumi IaC Pulumi ESC Pulumi Insights Pulumi Cloud Packages Tutorials
  1. Packages
  2. Tencentcloud Provider
  3. API Docs
  4. EbEventConnector
tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack
tencentcloudstack/terraform-provider-tencentcloud

tencentcloud.EbEventConnector

Explore with Pulumi AI

tencentcloud logo
tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack
tencentcloudstack/terraform-provider-tencentcloud

    Provides a resource to create a eb event_connector

    NOTE: When the type is apigw, the import function is not supported.

    Example Usage

    Create ckafka event connector

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

const fooUserInfo = tencentcloud.getUserInfo({});
const fooEbEventBus = new tencentcloud.EbEventBus("fooEbEventBus", {
    eventBusName: "tf-event_bus",
    description: "event bus desc",
    enableStore: false,
    saveDays: 1,
    tags: {
        createdBy: "terraform",
    },
});
const kafkaInstance = new tencentcloud.CkafkaInstance("kafkaInstance", {
    instanceName: "ckafka-instance-maz-tf-test",
    zoneId: 100003,
    multiZoneFlag: true,
    zoneIds: [
        100003,
        100006,
    ],
    period: 1,
    vpcId: _var.vpc_id,
    subnetId: _var.subnet_id,
    msgRetentionTime: 1300,
    renewFlag: 0,
    kafkaVersion: "1.1.1",
    diskSize: 500,
    diskType: "CLOUD_BASIC",
    config: {
        autoCreateTopicEnable: true,
        defaultNumPartitions: 3,
        defaultReplicationFactor: 3,
    },
    dynamicRetentionConfig: {
        enable: 1,
    },
});
const ckafkaId = kafkaInstance.ckafkaInstanceId;
const uin = fooUserInfo.then(fooUserInfo => fooUserInfo.ownerUin);
const eventConnector = new tencentcloud.EbEventConnector("eventConnector", {
    eventBusId: fooEbEventBus.ebEventBusId,
    connectionName: "tf-event-connector",
    description: "event connector desc1",
    enable: true,
    type: "ckafka",
    connectionDescription: {
        resourceDescription: pulumi.all([uin, uin, ckafkaId]).apply(([uin, uin1, ckafkaId]) => `qcs::ckafka:ap-guangzhou:uin/${uin}:ckafkaId/uin/${uin1}/${ckafkaId}`),
        ckafkaParams: {
            offset: "latest",
            topicName: "dasdasd",
        },
    },
});

    import pulumi
import pulumi_tencentcloud as tencentcloud

foo_user_info = tencentcloud.get_user_info()
foo_eb_event_bus = tencentcloud.EbEventBus("fooEbEventBus",
    event_bus_name="tf-event_bus",
    description="event bus desc",
    enable_store=False,
    save_days=1,
    tags={
        "createdBy": "terraform",
    })
kafka_instance = tencentcloud.CkafkaInstance("kafkaInstance",
    instance_name="ckafka-instance-maz-tf-test",
    zone_id=100003,
    multi_zone_flag=True,
    zone_ids=[
        100003,
        100006,
    ],
    period=1,
    vpc_id=var["vpc_id"],
    subnet_id=var["subnet_id"],
    msg_retention_time=1300,
    renew_flag=0,
    kafka_version="1.1.1",
    disk_size=500,
    disk_type="CLOUD_BASIC",
    config={
        "auto_create_topic_enable": True,
        "default_num_partitions": 3,
        "default_replication_factor": 3,
    },
    dynamic_retention_config={
        "enable": 1,
    })
ckafka_id = kafka_instance.ckafka_instance_id
uin = foo_user_info.owner_uin
event_connector = tencentcloud.EbEventConnector("eventConnector",
    event_bus_id=foo_eb_event_bus.eb_event_bus_id,
    connection_name="tf-event-connector",
    description="event connector desc1",
    enable=True,
    type="ckafka",
    connection_description={
        "resource_description": ckafka_id.apply(lambda ckafka_id: f"qcs::ckafka:ap-guangzhou:uin/{uin}:ckafkaId/uin/{uin}/{ckafka_id}"),
        "ckafka_params": {
            "offset": "latest",
            "topic_name": "dasdasd",
        },
    })

    package main

import (
	"fmt"

	"github.com/pulumi/pulumi-terraform-provider/sdks/go/tencentcloud/tencentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		fooUserInfo, err := tencentcloud.GetUserInfo(ctx, &tencentcloud.GetUserInfoArgs{}, nil)
		if err != nil {
			return err
		}
		fooEbEventBus, err := tencentcloud.NewEbEventBus(ctx, "fooEbEventBus", &tencentcloud.EbEventBusArgs{
			EventBusName: pulumi.String("tf-event_bus"),
			Description:  pulumi.String("event bus desc"),
			EnableStore:  pulumi.Bool(false),
			SaveDays:     pulumi.Float64(1),
			Tags: pulumi.StringMap{
				"createdBy": pulumi.String("terraform"),
			},
		})
		if err != nil {
			return err
		}
		kafkaInstance, err := tencentcloud.NewCkafkaInstance(ctx, "kafkaInstance", &tencentcloud.CkafkaInstanceArgs{
			InstanceName:  pulumi.String("ckafka-instance-maz-tf-test"),
			ZoneId:        pulumi.Float64(100003),
			MultiZoneFlag: pulumi.Bool(true),
			ZoneIds: pulumi.Float64Array{
				pulumi.Float64(100003),
				pulumi.Float64(100006),
			},
			Period:           pulumi.Float64(1),
			VpcId:            pulumi.Any(_var.Vpc_id),
			SubnetId:         pulumi.Any(_var.Subnet_id),
			MsgRetentionTime: pulumi.Float64(1300),
			RenewFlag:        pulumi.Float64(0),
			KafkaVersion:     pulumi.String("1.1.1"),
			DiskSize:         pulumi.Float64(500),
			DiskType:         pulumi.String("CLOUD_BASIC"),
			Config: &tencentcloud.CkafkaInstanceConfigArgs{
				AutoCreateTopicEnable:    pulumi.Bool(true),
				DefaultNumPartitions:     pulumi.Float64(3),
				DefaultReplicationFactor: pulumi.Float64(3),
			},
			DynamicRetentionConfig: &tencentcloud.CkafkaInstanceDynamicRetentionConfigArgs{
				Enable: pulumi.Float64(1),
			},
		})
		if err != nil {
			return err
		}
		ckafkaId := kafkaInstance.CkafkaInstanceId
		uin := fooUserInfo.OwnerUin
		_, err = tencentcloud.NewEbEventConnector(ctx, "eventConnector", &tencentcloud.EbEventConnectorArgs{
			EventBusId:     fooEbEventBus.EbEventBusId,
			ConnectionName: pulumi.String("tf-event-connector"),
			Description:    pulumi.String("event connector desc1"),
			Enable:         pulumi.Bool(true),
			Type:           pulumi.String("ckafka"),
			ConnectionDescription: &tencentcloud.EbEventConnectorConnectionDescriptionArgs{
				ResourceDescription: ckafkaId.ApplyT(func(ckafkaId string) (string, error) {
					return fmt.Sprintf("qcs::ckafka:ap-guangzhou:uin/%v:ckafkaId/uin/%v/%v", uin, uin, ckafkaId), nil
				}).(pulumi.StringOutput),
				CkafkaParams: &tencentcloud.EbEventConnectorConnectionDescriptionCkafkaParamsArgs{
					Offset:    pulumi.String("latest"),
					TopicName: pulumi.String("dasdasd"),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Tencentcloud = Pulumi.Tencentcloud;

return await Deployment.RunAsync(() => 
{
    var fooUserInfo = Tencentcloud.GetUserInfo.Invoke();

    var fooEbEventBus = new Tencentcloud.EbEventBus("fooEbEventBus", new()
    {
        EventBusName = "tf-event_bus",
        Description = "event bus desc",
        EnableStore = false,
        SaveDays = 1,
        Tags = 
        {
            { "createdBy", "terraform" },
        },
    });

    var kafkaInstance = new Tencentcloud.CkafkaInstance("kafkaInstance", new()
    {
        InstanceName = "ckafka-instance-maz-tf-test",
        ZoneId = 100003,
        MultiZoneFlag = true,
        ZoneIds = new[]
        {
            100003,
            100006,
        },
        Period = 1,
        VpcId = @var.Vpc_id,
        SubnetId = @var.Subnet_id,
        MsgRetentionTime = 1300,
        RenewFlag = 0,
        KafkaVersion = "1.1.1",
        DiskSize = 500,
        DiskType = "CLOUD_BASIC",
        Config = new Tencentcloud.Inputs.CkafkaInstanceConfigArgs
        {
            AutoCreateTopicEnable = true,
            DefaultNumPartitions = 3,
            DefaultReplicationFactor = 3,
        },
        DynamicRetentionConfig = new Tencentcloud.Inputs.CkafkaInstanceDynamicRetentionConfigArgs
        {
            Enable = 1,
        },
    });

    var ckafkaId = kafkaInstance.CkafkaInstanceId;

    var uin = fooUserInfo.Apply(getUserInfoResult => getUserInfoResult.OwnerUin);

    var eventConnector = new Tencentcloud.EbEventConnector("eventConnector", new()
    {
        EventBusId = fooEbEventBus.EbEventBusId,
        ConnectionName = "tf-event-connector",
        Description = "event connector desc1",
        Enable = true,
        Type = "ckafka",
        ConnectionDescription = new Tencentcloud.Inputs.EbEventConnectorConnectionDescriptionArgs
        {
            ResourceDescription = Output.Tuple(uin, uin, ckafkaId).Apply(values =>
            {
                var uin = values.Item1;
                var uin1 = values.Item2;
                var ckafkaId = values.Item3;
                return $"qcs::ckafka:ap-guangzhou:uin/{uin}:ckafkaId/uin/{uin1}/{ckafkaId}";
            }),
            CkafkaParams = new Tencentcloud.Inputs.EbEventConnectorConnectionDescriptionCkafkaParamsArgs
            {
                Offset = "latest",
                TopicName = "dasdasd",
            },
        },
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.tencentcloud.TencentcloudFunctions;
import com.pulumi.tencentcloud.inputs.GetUserInfoArgs;
import com.pulumi.tencentcloud.EbEventBus;
import com.pulumi.tencentcloud.EbEventBusArgs;
import com.pulumi.tencentcloud.CkafkaInstance;
import com.pulumi.tencentcloud.CkafkaInstanceArgs;
import com.pulumi.tencentcloud.inputs.CkafkaInstanceConfigArgs;
import com.pulumi.tencentcloud.inputs.CkafkaInstanceDynamicRetentionConfigArgs;
import com.pulumi.tencentcloud.EbEventConnector;
import com.pulumi.tencentcloud.EbEventConnectorArgs;
import com.pulumi.tencentcloud.inputs.EbEventConnectorConnectionDescriptionArgs;
import com.pulumi.tencentcloud.inputs.EbEventConnectorConnectionDescriptionCkafkaParamsArgs;
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 fooUserInfo = TencentcloudFunctions.getUserInfo();

        var fooEbEventBus = new EbEventBus("fooEbEventBus", EbEventBusArgs.builder()
            .eventBusName("tf-event_bus")
            .description("event bus desc")
            .enableStore(false)
            .saveDays(1)
            .tags(Map.of("createdBy", "terraform"))
            .build());

        var kafkaInstance = new CkafkaInstance("kafkaInstance", CkafkaInstanceArgs.builder()
            .instanceName("ckafka-instance-maz-tf-test")
            .zoneId(100003)
            .multiZoneFlag(true)
            .zoneIds(            
                100003,
                100006)
            .period(1)
            .vpcId(var_.vpc_id())
            .subnetId(var_.subnet_id())
            .msgRetentionTime(1300)
            .renewFlag(0)
            .kafkaVersion("1.1.1")
            .diskSize(500)
            .diskType("CLOUD_BASIC")
            .config(CkafkaInstanceConfigArgs.builder()
                .autoCreateTopicEnable(true)
                .defaultNumPartitions(3)
                .defaultReplicationFactor(3)
                .build())
            .dynamicRetentionConfig(CkafkaInstanceDynamicRetentionConfigArgs.builder()
                .enable(1)
                .build())
            .build());

        final var ckafkaId = kafkaInstance.ckafkaInstanceId();

        final var uin = fooUserInfo.applyValue(getUserInfoResult -> getUserInfoResult.ownerUin());

        var eventConnector = new EbEventConnector("eventConnector", EbEventConnectorArgs.builder()
            .eventBusId(fooEbEventBus.ebEventBusId())
            .connectionName("tf-event-connector")
            .description("event connector desc1")
            .enable(true)
            .type("ckafka")
            .connectionDescription(EbEventConnectorConnectionDescriptionArgs.builder()
                .resourceDescription(ckafkaId.applyValue(ckafkaId -> String.format("qcs::ckafka:ap-guangzhou:uin/%s:ckafkaId/uin/%s/%s", uin,uin,ckafkaId)))
                .ckafkaParams(EbEventConnectorConnectionDescriptionCkafkaParamsArgs.builder()
                    .offset("latest")
                    .topicName("dasdasd")
                    .build())
                .build())
            .build());

    }
}

    resources:
  fooEbEventBus:
    type: tencentcloud:EbEventBus
    properties:
      eventBusName: tf-event_bus
      description: event bus desc
      enableStore: false
      saveDays: 1
      tags:
        createdBy: terraform
  kafkaInstance:
    type: tencentcloud:CkafkaInstance
    properties:
      instanceName: ckafka-instance-maz-tf-test
      zoneId: 100003
      multiZoneFlag: true
      zoneIds:
        - 100003
        - 100006
      period: 1
      vpcId: ${var.vpc_id}
      subnetId: ${var.subnet_id}
      msgRetentionTime: 1300
      renewFlag: 0
      kafkaVersion: 1.1.1
      diskSize: 500
      diskType: CLOUD_BASIC
      config:
        autoCreateTopicEnable: true
        defaultNumPartitions: 3
        defaultReplicationFactor: 3
      dynamicRetentionConfig:
        enable: 1
  eventConnector:
    type: tencentcloud:EbEventConnector
    properties:
      eventBusId: ${fooEbEventBus.ebEventBusId}
      connectionName: tf-event-connector
      description: event connector desc1
      enable: true
      type: ckafka
      connectionDescription:
        resourceDescription: qcs::ckafka:ap-guangzhou:uin/${uin}:ckafkaId/uin/${uin}/${ckafkaId}
        ckafkaParams:
          offset: latest
          topicName: dasdasd
variables:
  fooUserInfo:
    fn::invoke:
      function: tencentcloud:getUserInfo
      arguments: {}
  ckafkaId: ${kafkaInstance.ckafkaInstanceId}
  uin: ${fooUserInfo.ownerUin}

    Create api_gateway event connector

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

const fooUserInfo = tencentcloud.getUserInfo({});
const fooEbEventBus = new tencentcloud.EbEventBus("fooEbEventBus", {
    eventBusName: "tf-event_bus",
    description: "event bus desc",
    enableStore: false,
    saveDays: 1,
    tags: {
        createdBy: "terraform",
    },
});
const service = new tencentcloud.ApiGatewayService("service", {
    serviceName: "tf-eb-service",
    protocol: "http&https",
    serviceDesc: "your nice service",
    netTypes: [
        "INNER",
        "OUTER",
    ],
    ipVersion: "IPv4",
});
const uin = fooUserInfo.then(fooUserInfo => fooUserInfo.ownerUin);
const serviceId = service.apiGatewayServiceId;
const eventConnector = new tencentcloud.EbEventConnector("eventConnector", {
    eventBusId: fooEbEventBus.ebEventBusId,
    connectionName: "tf-event-connector",
    description: "event connector desc1",
    enable: false,
    type: "apigw",
    connectionDescription: {
        resourceDescription: pulumi.all([uin, serviceId]).apply(([uin, serviceId]) => `qcs::apigw:ap-guangzhou:uin/${uin}:serviceid/${serviceId}`),
        apiGwParams: {
            protocol: "HTTP",
            method: "GET",
        },
    },
});

    import pulumi
import pulumi_tencentcloud as tencentcloud

foo_user_info = tencentcloud.get_user_info()
foo_eb_event_bus = tencentcloud.EbEventBus("fooEbEventBus",
    event_bus_name="tf-event_bus",
    description="event bus desc",
    enable_store=False,
    save_days=1,
    tags={
        "createdBy": "terraform",
    })
service = tencentcloud.ApiGatewayService("service",
    service_name="tf-eb-service",
    protocol="http&https",
    service_desc="your nice service",
    net_types=[
        "INNER",
        "OUTER",
    ],
    ip_version="IPv4")
uin = foo_user_info.owner_uin
service_id = service.api_gateway_service_id
event_connector = tencentcloud.EbEventConnector("eventConnector",
    event_bus_id=foo_eb_event_bus.eb_event_bus_id,
    connection_name="tf-event-connector",
    description="event connector desc1",
    enable=False,
    type="apigw",
    connection_description={
        "resource_description": service_id.apply(lambda service_id: f"qcs::apigw:ap-guangzhou:uin/{uin}:serviceid/{service_id}"),
        "api_gw_params": {
            "protocol": "HTTP",
            "method": "GET",
        },
    })

    package main

import (
	"fmt"

	"github.com/pulumi/pulumi-terraform-provider/sdks/go/tencentcloud/tencentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		fooUserInfo, err := tencentcloud.GetUserInfo(ctx, &tencentcloud.GetUserInfoArgs{}, nil)
		if err != nil {
			return err
		}
		fooEbEventBus, err := tencentcloud.NewEbEventBus(ctx, "fooEbEventBus", &tencentcloud.EbEventBusArgs{
			EventBusName: pulumi.String("tf-event_bus"),
			Description:  pulumi.String("event bus desc"),
			EnableStore:  pulumi.Bool(false),
			SaveDays:     pulumi.Float64(1),
			Tags: pulumi.StringMap{
				"createdBy": pulumi.String("terraform"),
			},
		})
		if err != nil {
			return err
		}
		service, err := tencentcloud.NewApiGatewayService(ctx, "service", &tencentcloud.ApiGatewayServiceArgs{
			ServiceName: pulumi.String("tf-eb-service"),
			Protocol:    pulumi.String("http&https"),
			ServiceDesc: pulumi.String("your nice service"),
			NetTypes: pulumi.StringArray{
				pulumi.String("INNER"),
				pulumi.String("OUTER"),
			},
			IpVersion: pulumi.String("IPv4"),
		})
		if err != nil {
			return err
		}
		uin := fooUserInfo.OwnerUin
		serviceId := service.ApiGatewayServiceId
		_, err = tencentcloud.NewEbEventConnector(ctx, "eventConnector", &tencentcloud.EbEventConnectorArgs{
			EventBusId:     fooEbEventBus.EbEventBusId,
			ConnectionName: pulumi.String("tf-event-connector"),
			Description:    pulumi.String("event connector desc1"),
			Enable:         pulumi.Bool(false),
			Type:           pulumi.String("apigw"),
			ConnectionDescription: &tencentcloud.EbEventConnectorConnectionDescriptionArgs{
				ResourceDescription: serviceId.ApplyT(func(serviceId string) (string, error) {
					return fmt.Sprintf("qcs::apigw:ap-guangzhou:uin/%v:serviceid/%v", uin, serviceId), nil
				}).(pulumi.StringOutput),
				ApiGwParams: &tencentcloud.EbEventConnectorConnectionDescriptionApiGwParamsArgs{
					Protocol: pulumi.String("HTTP"),
					Method:   pulumi.String("GET"),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Tencentcloud = Pulumi.Tencentcloud;

return await Deployment.RunAsync(() => 
{
    var fooUserInfo = Tencentcloud.GetUserInfo.Invoke();

    var fooEbEventBus = new Tencentcloud.EbEventBus("fooEbEventBus", new()
    {
        EventBusName = "tf-event_bus",
        Description = "event bus desc",
        EnableStore = false,
        SaveDays = 1,
        Tags = 
        {
            { "createdBy", "terraform" },
        },
    });

    var service = new Tencentcloud.ApiGatewayService("service", new()
    {
        ServiceName = "tf-eb-service",
        Protocol = "http&https",
        ServiceDesc = "your nice service",
        NetTypes = new[]
        {
            "INNER",
            "OUTER",
        },
        IpVersion = "IPv4",
    });

    var uin = fooUserInfo.Apply(getUserInfoResult => getUserInfoResult.OwnerUin);

    var serviceId = service.ApiGatewayServiceId;

    var eventConnector = new Tencentcloud.EbEventConnector("eventConnector", new()
    {
        EventBusId = fooEbEventBus.EbEventBusId,
        ConnectionName = "tf-event-connector",
        Description = "event connector desc1",
        Enable = false,
        Type = "apigw",
        ConnectionDescription = new Tencentcloud.Inputs.EbEventConnectorConnectionDescriptionArgs
        {
            ResourceDescription = Output.Tuple(uin, serviceId).Apply(values =>
            {
                var uin = values.Item1;
                var serviceId = values.Item2;
                return $"qcs::apigw:ap-guangzhou:uin/{uin}:serviceid/{serviceId}";
            }),
            ApiGwParams = new Tencentcloud.Inputs.EbEventConnectorConnectionDescriptionApiGwParamsArgs
            {
                Protocol = "HTTP",
                Method = "GET",
            },
        },
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.tencentcloud.TencentcloudFunctions;
import com.pulumi.tencentcloud.inputs.GetUserInfoArgs;
import com.pulumi.tencentcloud.EbEventBus;
import com.pulumi.tencentcloud.EbEventBusArgs;
import com.pulumi.tencentcloud.ApiGatewayService;
import com.pulumi.tencentcloud.ApiGatewayServiceArgs;
import com.pulumi.tencentcloud.EbEventConnector;
import com.pulumi.tencentcloud.EbEventConnectorArgs;
import com.pulumi.tencentcloud.inputs.EbEventConnectorConnectionDescriptionArgs;
import com.pulumi.tencentcloud.inputs.EbEventConnectorConnectionDescriptionApiGwParamsArgs;
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 fooUserInfo = TencentcloudFunctions.getUserInfo();

        var fooEbEventBus = new EbEventBus("fooEbEventBus", EbEventBusArgs.builder()
            .eventBusName("tf-event_bus")
            .description("event bus desc")
            .enableStore(false)
            .saveDays(1)
            .tags(Map.of("createdBy", "terraform"))
            .build());

        var service = new ApiGatewayService("service", ApiGatewayServiceArgs.builder()
            .serviceName("tf-eb-service")
            .protocol("http&https")
            .serviceDesc("your nice service")
            .netTypes(            
                "INNER",
                "OUTER")
            .ipVersion("IPv4")
            .build());

        final var uin = fooUserInfo.applyValue(getUserInfoResult -> getUserInfoResult.ownerUin());

        final var serviceId = service.apiGatewayServiceId();

        var eventConnector = new EbEventConnector("eventConnector", EbEventConnectorArgs.builder()
            .eventBusId(fooEbEventBus.ebEventBusId())
            .connectionName("tf-event-connector")
            .description("event connector desc1")
            .enable(false)
            .type("apigw")
            .connectionDescription(EbEventConnectorConnectionDescriptionArgs.builder()
                .resourceDescription(serviceId.applyValue(serviceId -> String.format("qcs::apigw:ap-guangzhou:uin/%s:serviceid/%s", uin,serviceId)))
                .apiGwParams(EbEventConnectorConnectionDescriptionApiGwParamsArgs.builder()
                    .protocol("HTTP")
                    .method("GET")
                    .build())
                .build())
            .build());

    }
}

    resources:
  fooEbEventBus:
    type: tencentcloud:EbEventBus
    properties:
      eventBusName: tf-event_bus
      description: event bus desc
      enableStore: false
      saveDays: 1
      tags:
        createdBy: terraform
  service:
    type: tencentcloud:ApiGatewayService
    properties:
      serviceName: tf-eb-service
      protocol: http&https
      serviceDesc: your nice service
      netTypes:
        - INNER
        - OUTER
      ipVersion: IPv4
  eventConnector:
    type: tencentcloud:EbEventConnector
    properties:
      eventBusId: ${fooEbEventBus.ebEventBusId}
      connectionName: tf-event-connector
      description: event connector desc1
      enable: false
      type: apigw
      connectionDescription:
        resourceDescription: qcs::apigw:ap-guangzhou:uin/${uin}:serviceid/${serviceId}
        apiGwParams:
          protocol: HTTP
          method: GET
variables:
  fooUserInfo:
    fn::invoke:
      function: tencentcloud:getUserInfo
      arguments: {}
  uin: ${fooUserInfo.ownerUin}
  serviceId: ${service.apiGatewayServiceId}

    Create EbEventConnector Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new EbEventConnector(name: string, args: EbEventConnectorArgs, opts?: CustomResourceOptions);
    @overload
def EbEventConnector(resource_name: str,
                     args: EbEventConnectorArgs,
                     opts: Optional[ResourceOptions] = None)

@overload
def EbEventConnector(resource_name: str,
                     opts: Optional[ResourceOptions] = None,
                     connection_description: Optional[EbEventConnectorConnectionDescriptionArgs] = None,
                     connection_name: Optional[str] = None,
                     event_bus_id: Optional[str] = None,
                     description: Optional[str] = None,
                     eb_event_connector_id: Optional[str] = None,
                     enable: Optional[bool] = None,
                     type: Optional[str] = None)
    func NewEbEventConnector(ctx *Context, name string, args EbEventConnectorArgs, opts ...ResourceOption) (*EbEventConnector, error)
    public EbEventConnector(string name, EbEventConnectorArgs args, CustomResourceOptions? opts = null)
    public EbEventConnector(String name, EbEventConnectorArgs args)
public EbEventConnector(String name, EbEventConnectorArgs args, CustomResourceOptions options)

    type: tencentcloud:EbEventConnector
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

    Parameters

    name string
    The unique name of the resource.
    args EbEventConnectorArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    resource_name str
    The unique name of the resource.
    args EbEventConnectorArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control resource's behavior.
    ctx Context
    Context object for the current deployment.
    name string
    The unique name of the resource.
    args EbEventConnectorArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args EbEventConnectorArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args EbEventConnectorArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    EbEventConnector Resource Properties

    To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

    Inputs

    In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

    The EbEventConnector resource accepts the following input properties:

    ConnectionDescription EbEventConnectorConnectionDescription
    Connector description.
    ConnectionName string
    connector name.
    EventBusId string
    event bus Id.
    Description string
    description.
    EbEventConnectorId string
    ID of the resource.
    Enable bool
    switch.
    Type string
    type.
    ConnectionDescription EbEventConnectorConnectionDescriptionArgs
    Connector description.
    ConnectionName string
    connector name.
    EventBusId string
    event bus Id.
    Description string
    description.
    EbEventConnectorId string
    ID of the resource.
    Enable bool
    switch.
    Type string
    type.
    connectionDescription EbEventConnectorConnectionDescription
    Connector description.
    connectionName String
    connector name.
    eventBusId String
    event bus Id.
    description String
    description.
    ebEventConnectorId String
    ID of the resource.
    enable Boolean
    switch.
    type String
    type.
    connectionDescription EbEventConnectorConnectionDescription
    Connector description.
    connectionName string
    connector name.
    eventBusId string
    event bus Id.
    description string
    description.
    ebEventConnectorId string
    ID of the resource.
    enable boolean
    switch.
    type string
    type.
    connection_description EbEventConnectorConnectionDescriptionArgs
    Connector description.
    connection_name str
    connector name.
    event_bus_id str
    event bus Id.
    description str
    description.
    eb_event_connector_id str
    ID of the resource.
    enable bool
    switch.
    type str
    type.
    connectionDescription Property Map
    Connector description.
    connectionName String
    connector name.
    eventBusId String
    event bus Id.
    description String
    description.
    ebEventConnectorId String
    ID of the resource.
    enable Boolean
    switch.
    type String
    type.

    Outputs

    All input properties are implicitly available as output properties. Additionally, the EbEventConnector resource produces the following output properties:

    Id string
    The provider-assigned unique ID for this managed resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.
    id string
    The provider-assigned unique ID for this managed resource.
    id str
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.

    Look up Existing EbEventConnector Resource

    Get an existing EbEventConnector resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

    public static get(name: string, id: Input<ID>, state?: EbEventConnectorState, opts?: CustomResourceOptions): EbEventConnector
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        connection_description: Optional[EbEventConnectorConnectionDescriptionArgs] = None,
        connection_name: Optional[str] = None,
        description: Optional[str] = None,
        eb_event_connector_id: Optional[str] = None,
        enable: Optional[bool] = None,
        event_bus_id: Optional[str] = None,
        type: Optional[str] = None) -> EbEventConnector
    func GetEbEventConnector(ctx *Context, name string, id IDInput, state *EbEventConnectorState, opts ...ResourceOption) (*EbEventConnector, error)
    public static EbEventConnector Get(string name, Input<string> id, EbEventConnectorState? state, CustomResourceOptions? opts = null)
    public static EbEventConnector get(String name, Output<String> id, EbEventConnectorState state, CustomResourceOptions options)
    resources:  _:    type: tencentcloud:EbEventConnector    get:      id: ${id}
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    resource_name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    The following state arguments are supported:
    ConnectionDescription EbEventConnectorConnectionDescription
    Connector description.
    ConnectionName string
    connector name.
    Description string
    description.
    EbEventConnectorId string
    ID of the resource.
    Enable bool
    switch.
    EventBusId string
    event bus Id.
    Type string
    type.
    ConnectionDescription EbEventConnectorConnectionDescriptionArgs
    Connector description.
    ConnectionName string
    connector name.
    Description string
    description.
    EbEventConnectorId string
    ID of the resource.
    Enable bool
    switch.
    EventBusId string
    event bus Id.
    Type string
    type.
    connectionDescription EbEventConnectorConnectionDescription
    Connector description.
    connectionName String
    connector name.
    description String
    description.
    ebEventConnectorId String
    ID of the resource.
    enable Boolean
    switch.
    eventBusId String
    event bus Id.
    type String
    type.
    connectionDescription EbEventConnectorConnectionDescription
    Connector description.
    connectionName string
    connector name.
    description string
    description.
    ebEventConnectorId string
    ID of the resource.
    enable boolean
    switch.
    eventBusId string
    event bus Id.
    type string
    type.
    connection_description EbEventConnectorConnectionDescriptionArgs
    Connector description.
    connection_name str
    connector name.
    description str
    description.
    eb_event_connector_id str
    ID of the resource.
    enable bool
    switch.
    event_bus_id str
    event bus Id.
    type str
    type.
    connectionDescription Property Map
    Connector description.
    connectionName String
    connector name.
    description String
    description.
    ebEventConnectorId String
    ID of the resource.
    enable Boolean
    switch.
    eventBusId String
    event bus Id.
    type String
    type.

    Supporting Types

    EbEventConnectorConnectionDescription, EbEventConnectorConnectionDescriptionArgs

    ResourceDescription string
    Resource qcs six-segment style, more reference resource six-segment style.
    ApiGwParams EbEventConnectorConnectionDescriptionApiGwParams
    apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
    CkafkaParams EbEventConnectorConnectionDescriptionCkafkaParams
    ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.
    ResourceDescription string
    Resource qcs six-segment style, more reference resource six-segment style.
    ApiGwParams EbEventConnectorConnectionDescriptionApiGwParams
    apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
    CkafkaParams EbEventConnectorConnectionDescriptionCkafkaParams
    ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.
    resourceDescription String
    Resource qcs six-segment style, more reference resource six-segment style.
    apiGwParams EbEventConnectorConnectionDescriptionApiGwParams
    apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
    ckafkaParams EbEventConnectorConnectionDescriptionCkafkaParams
    ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.
    resourceDescription string
    Resource qcs six-segment style, more reference resource six-segment style.
    apiGwParams EbEventConnectorConnectionDescriptionApiGwParams
    apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
    ckafkaParams EbEventConnectorConnectionDescriptionCkafkaParams
    ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.
    resource_description str
    Resource qcs six-segment style, more reference resource six-segment style.
    api_gw_params EbEventConnectorConnectionDescriptionApiGwParams
    apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
    ckafka_params EbEventConnectorConnectionDescriptionCkafkaParams
    ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.
    resourceDescription String
    Resource qcs six-segment style, more reference resource six-segment style.
    apiGwParams Property Map
    apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
    ckafkaParams Property Map
    ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.

    EbEventConnectorConnectionDescriptionApiGwParams, EbEventConnectorConnectionDescriptionApiGwParamsArgs

    Method string
    POST.
    Protocol string
    HTTPS.
    Method string
    POST.
    Protocol string
    HTTPS.
    method String
    POST.
    protocol String
    HTTPS.
    method string
    POST.
    protocol string
    HTTPS.
    method str
    POST.
    protocol str
    HTTPS.
    method String
    POST.
    protocol String
    HTTPS.

    EbEventConnectorConnectionDescriptionCkafkaParams, EbEventConnectorConnectionDescriptionCkafkaParamsArgs

    Offset string
    kafka offset.
    TopicName string
    ckafka topic.
    Offset string
    kafka offset.
    TopicName string
    ckafka topic.
    offset String
    kafka offset.
    topicName String
    ckafka topic.
    offset string
    kafka offset.
    topicName string
    ckafka topic.
    offset str
    kafka offset.
    topic_name str
    ckafka topic.
    offset String
    kafka offset.
    topicName String
    ckafka topic.

    Import

    eb event_connector can be imported using the id, e.g.

    $ pulumi import tencentcloud:index/ebEventConnector:EbEventConnector event_connector eventBusId#connectionId

    To learn more about importing existing cloud resources, see Importing resources.

    Package Details

    Repository
    tencentcloud tencentcloudstack/terraform-provider-tencentcloud
    License
    Notes
    This Pulumi package is based on the tencentcloud Terraform Provider.
    tencentcloud logo
    tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack
    tencentcloudstack/terraform-provider-tencentcloud