Docs Home Pulumi IaC Pulumi ESC Pulumi Insights Pulumi IDP Pulumi Cloud Packages Tutorials
  1. Packages
  2. Volcengine
  3. API Docs
  4. vefaas
  5. KafkaTrigger
Volcengine v0.0.34 published on Wednesday, Jul 2, 2025 by Volcengine
volcengine/pulumi-volcengine

volcengine.vefaas.KafkaTrigger

Explore with Pulumi AI

volcengine logo
Volcengine v0.0.34 published on Wednesday, Jul 2, 2025 by Volcengine
volcengine/pulumi-volcengine

    Provides a resource to manage vefaas kafka trigger

    Example Usage

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

const foo = new volcengine.vefaas.KafkaTrigger("foo", {
    functionId: "35ybaxxx",
    mqInstanceId: "kafka-cnngmbeq10mcxxxx",
    topicName: "topic",
    kafkaCredentials: {
        password: "Waxxxxxx",
        username: "test-1",
        mechanism: "PLAIN",
    },
    batchSize: 100,
    description: "modify",
});

    import pulumi
import pulumi_volcengine as volcengine

foo = volcengine.vefaas.KafkaTrigger("foo",
    function_id="35ybaxxx",
    mq_instance_id="kafka-cnngmbeq10mcxxxx",
    topic_name="topic",
    kafka_credentials=volcengine.vefaas.KafkaTriggerKafkaCredentialsArgs(
        password="Waxxxxxx",
        username="test-1",
        mechanism="PLAIN",
    ),
    batch_size=100,
    description="modify")

    package main

import (
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
	"github.com/volcengine/pulumi-volcengine/sdk/go/volcengine/vefaas"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := vefaas.NewKafkaTrigger(ctx, "foo", &vefaas.KafkaTriggerArgs{
			FunctionId:   pulumi.String("35ybaxxx"),
			MqInstanceId: pulumi.String("kafka-cnngmbeq10mcxxxx"),
			TopicName:    pulumi.String("topic"),
			KafkaCredentials: &vefaas.KafkaTriggerKafkaCredentialsArgs{
				Password:  pulumi.String("Waxxxxxx"),
				Username:  pulumi.String("test-1"),
				Mechanism: pulumi.String("PLAIN"),
			},
			BatchSize:   pulumi.Int(100),
			Description: pulumi.String("modify"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

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

return await Deployment.RunAsync(() => 
{
    var foo = new Volcengine.Vefaas.KafkaTrigger("foo", new()
    {
        FunctionId = "35ybaxxx",
        MqInstanceId = "kafka-cnngmbeq10mcxxxx",
        TopicName = "topic",
        KafkaCredentials = new Volcengine.Vefaas.Inputs.KafkaTriggerKafkaCredentialsArgs
        {
            Password = "Waxxxxxx",
            Username = "test-1",
            Mechanism = "PLAIN",
        },
        BatchSize = 100,
        Description = "modify",
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.volcengine.vefaas.KafkaTrigger;
import com.pulumi.volcengine.vefaas.KafkaTriggerArgs;
import com.pulumi.volcengine.vefaas.inputs.KafkaTriggerKafkaCredentialsArgs;
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) {
        var foo = new KafkaTrigger("foo", KafkaTriggerArgs.builder()        
            .functionId("35ybaxxx")
            .mqInstanceId("kafka-cnngmbeq10mcxxxx")
            .topicName("topic")
            .kafkaCredentials(KafkaTriggerKafkaCredentialsArgs.builder()
                .password("Waxxxxxx")
                .username("test-1")
                .mechanism("PLAIN")
                .build())
            .batchSize(100)
            .description("modify")
            .build());

    }
}

    resources:
  foo:
    type: volcengine:vefaas:KafkaTrigger
    properties:
      functionId: 35ybaxxx
      mqInstanceId: kafka-cnngmbeq10mcxxxx
      topicName: topic
      kafkaCredentials:
        password: Waxxxxxx
        username: test-1
        mechanism: PLAIN
      batchSize: 100
      description: modify

    Create KafkaTrigger Resource

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

    Constructor syntax

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

@overload
def KafkaTrigger(resource_name: str,
                 opts: Optional[ResourceOptions] = None,
                 function_id: Optional[str] = None,
                 kafka_credentials: Optional[KafkaTriggerKafkaCredentialsArgs] = None,
                 mq_instance_id: Optional[str] = None,
                 topic_name: Optional[str] = None,
                 batch_flush_duration_milliseconds: Optional[int] = None,
                 batch_size: Optional[int] = None,
                 description: Optional[str] = None,
                 enabled: Optional[bool] = None,
                 maximum_retry_attempts: Optional[int] = None,
                 name: Optional[str] = None,
                 starting_position: Optional[str] = None)
    func NewKafkaTrigger(ctx *Context, name string, args KafkaTriggerArgs, opts ...ResourceOption) (*KafkaTrigger, error)
    public KafkaTrigger(string name, KafkaTriggerArgs args, CustomResourceOptions? opts = null)
    public KafkaTrigger(String name, KafkaTriggerArgs args)
public KafkaTrigger(String name, KafkaTriggerArgs args, CustomResourceOptions options)

    type: volcengine:vefaas:KafkaTrigger
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 KafkaTriggerArgs
    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 KafkaTriggerArgs
    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 KafkaTriggerArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args KafkaTriggerArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args KafkaTriggerArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Constructor example

    The following reference example uses placeholder values for all input properties.

    var kafkaTriggerResource = new Volcengine.Vefaas.KafkaTrigger("kafkaTriggerResource", new()
{
    FunctionId = "string",
    KafkaCredentials = new Volcengine.Vefaas.Inputs.KafkaTriggerKafkaCredentialsArgs
    {
        Mechanism = "string",
        Password = "string",
        Username = "string",
    },
    MqInstanceId = "string",
    TopicName = "string",
    BatchFlushDurationMilliseconds = 0,
    BatchSize = 0,
    Description = "string",
    Enabled = false,
    MaximumRetryAttempts = 0,
    Name = "string",
    StartingPosition = "string",
});

    example, err := vefaas.NewKafkaTrigger(ctx, "kafkaTriggerResource", &vefaas.KafkaTriggerArgs{
	FunctionId: pulumi.String("string"),
	KafkaCredentials: &vefaas.KafkaTriggerKafkaCredentialsArgs{
		Mechanism: pulumi.String("string"),
		Password:  pulumi.String("string"),
		Username:  pulumi.String("string"),
	},
	MqInstanceId:                   pulumi.String("string"),
	TopicName:                      pulumi.String("string"),
	BatchFlushDurationMilliseconds: pulumi.Int(0),
	BatchSize:                      pulumi.Int(0),
	Description:                    pulumi.String("string"),
	Enabled:                        pulumi.Bool(false),
	MaximumRetryAttempts:           pulumi.Int(0),
	Name:                           pulumi.String("string"),
	StartingPosition:               pulumi.String("string"),
})

    var kafkaTriggerResource = new KafkaTrigger("kafkaTriggerResource", KafkaTriggerArgs.builder()
    .functionId("string")
    .kafkaCredentials(KafkaTriggerKafkaCredentialsArgs.builder()
        .mechanism("string")
        .password("string")
        .username("string")
        .build())
    .mqInstanceId("string")
    .topicName("string")
    .batchFlushDurationMilliseconds(0)
    .batchSize(0)
    .description("string")
    .enabled(false)
    .maximumRetryAttempts(0)
    .name("string")
    .startingPosition("string")
    .build());

    kafka_trigger_resource = volcengine.vefaas.KafkaTrigger("kafkaTriggerResource",
    function_id="string",
    kafka_credentials={
        "mechanism": "string",
        "password": "string",
        "username": "string",
    },
    mq_instance_id="string",
    topic_name="string",
    batch_flush_duration_milliseconds=0,
    batch_size=0,
    description="string",
    enabled=False,
    maximum_retry_attempts=0,
    name="string",
    starting_position="string")

    const kafkaTriggerResource = new volcengine.vefaas.KafkaTrigger("kafkaTriggerResource", {
    functionId: "string",
    kafkaCredentials: {
        mechanism: "string",
        password: "string",
        username: "string",
    },
    mqInstanceId: "string",
    topicName: "string",
    batchFlushDurationMilliseconds: 0,
    batchSize: 0,
    description: "string",
    enabled: false,
    maximumRetryAttempts: 0,
    name: "string",
    startingPosition: "string",
});

    type: volcengine:vefaas:KafkaTrigger
properties:
    batchFlushDurationMilliseconds: 0
    batchSize: 0
    description: string
    enabled: false
    functionId: string
    kafkaCredentials:
        mechanism: string
        password: string
        username: string
    maximumRetryAttempts: 0
    mqInstanceId: string
    name: string
    startingPosition: string
    topicName: string

    KafkaTrigger 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 KafkaTrigger resource accepts the following input properties:

    FunctionId string
    The ID of Function.
    KafkaCredentials KafkaTriggerKafkaCredentials
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    MqInstanceId string
    The instance ID of Message queue Kafka.
    TopicName string
    The Topic name of the message queue Kafka instance.
    BatchFlushDurationMilliseconds int
    The maximum waiting time for batch consumption of triggers.
    BatchSize int
    The number of messages per batch consumed by the trigger in bulk.
    Description string
    The description of the Kafka trigger.
    Enabled bool
    Whether to enable triggers at the same time as creating them.
    MaximumRetryAttempts int
    The maximum number of retries when a function has a runtime error.
    Name string
    The name of the Kafka trigger.
    StartingPosition string
    Specify the location where the messages in the Topic start to be consumed.
    FunctionId string
    The ID of Function.
    KafkaCredentials KafkaTriggerKafkaCredentialsArgs
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    MqInstanceId string
    The instance ID of Message queue Kafka.
    TopicName string
    The Topic name of the message queue Kafka instance.
    BatchFlushDurationMilliseconds int
    The maximum waiting time for batch consumption of triggers.
    BatchSize int
    The number of messages per batch consumed by the trigger in bulk.
    Description string
    The description of the Kafka trigger.
    Enabled bool
    Whether to enable triggers at the same time as creating them.
    MaximumRetryAttempts int
    The maximum number of retries when a function has a runtime error.
    Name string
    The name of the Kafka trigger.
    StartingPosition string
    Specify the location where the messages in the Topic start to be consumed.
    functionId String
    The ID of Function.
    kafkaCredentials KafkaTriggerKafkaCredentials
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    mqInstanceId String
    The instance ID of Message queue Kafka.
    topicName String
    The Topic name of the message queue Kafka instance.
    batchFlushDurationMilliseconds Integer
    The maximum waiting time for batch consumption of triggers.
    batchSize Integer
    The number of messages per batch consumed by the trigger in bulk.
    description String
    The description of the Kafka trigger.
    enabled Boolean
    Whether to enable triggers at the same time as creating them.
    maximumRetryAttempts Integer
    The maximum number of retries when a function has a runtime error.
    name String
    The name of the Kafka trigger.
    startingPosition String
    Specify the location where the messages in the Topic start to be consumed.
    functionId string
    The ID of Function.
    kafkaCredentials KafkaTriggerKafkaCredentials
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    mqInstanceId string
    The instance ID of Message queue Kafka.
    topicName string
    The Topic name of the message queue Kafka instance.
    batchFlushDurationMilliseconds number
    The maximum waiting time for batch consumption of triggers.
    batchSize number
    The number of messages per batch consumed by the trigger in bulk.
    description string
    The description of the Kafka trigger.
    enabled boolean
    Whether to enable triggers at the same time as creating them.
    maximumRetryAttempts number
    The maximum number of retries when a function has a runtime error.
    name string
    The name of the Kafka trigger.
    startingPosition string
    Specify the location where the messages in the Topic start to be consumed.
    function_id str
    The ID of Function.
    kafka_credentials KafkaTriggerKafkaCredentialsArgs
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    mq_instance_id str
    The instance ID of Message queue Kafka.
    topic_name str
    The Topic name of the message queue Kafka instance.
    batch_flush_duration_milliseconds int
    The maximum waiting time for batch consumption of triggers.
    batch_size int
    The number of messages per batch consumed by the trigger in bulk.
    description str
    The description of the Kafka trigger.
    enabled bool
    Whether to enable triggers at the same time as creating them.
    maximum_retry_attempts int
    The maximum number of retries when a function has a runtime error.
    name str
    The name of the Kafka trigger.
    starting_position str
    Specify the location where the messages in the Topic start to be consumed.
    functionId String
    The ID of Function.
    kafkaCredentials Property Map
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    mqInstanceId String
    The instance ID of Message queue Kafka.
    topicName String
    The Topic name of the message queue Kafka instance.
    batchFlushDurationMilliseconds Number
    The maximum waiting time for batch consumption of triggers.
    batchSize Number
    The number of messages per batch consumed by the trigger in bulk.
    description String
    The description of the Kafka trigger.
    enabled Boolean
    Whether to enable triggers at the same time as creating them.
    maximumRetryAttempts Number
    The maximum number of retries when a function has a runtime error.
    name String
    The name of the Kafka trigger.
    startingPosition String
    Specify the location where the messages in the Topic start to be consumed.

    Outputs

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

    ConsumerGroup string
    The consumer group name of the message queue Kafka instance.
    CreationTime string
    The creation time of the Kafka trigger.
    Id string
    The provider-assigned unique ID for this managed resource.
    LastUpdateTime string
    The last update time of the Kafka trigger.
    Status string
    The status of Kafka trigger.
    ConsumerGroup string
    The consumer group name of the message queue Kafka instance.
    CreationTime string
    The creation time of the Kafka trigger.
    Id string
    The provider-assigned unique ID for this managed resource.
    LastUpdateTime string
    The last update time of the Kafka trigger.
    Status string
    The status of Kafka trigger.
    consumerGroup String
    The consumer group name of the message queue Kafka instance.
    creationTime String
    The creation time of the Kafka trigger.
    id String
    The provider-assigned unique ID for this managed resource.
    lastUpdateTime String
    The last update time of the Kafka trigger.
    status String
    The status of Kafka trigger.
    consumerGroup string
    The consumer group name of the message queue Kafka instance.
    creationTime string
    The creation time of the Kafka trigger.
    id string
    The provider-assigned unique ID for this managed resource.
    lastUpdateTime string
    The last update time of the Kafka trigger.
    status string
    The status of Kafka trigger.
    consumer_group str
    The consumer group name of the message queue Kafka instance.
    creation_time str
    The creation time of the Kafka trigger.
    id str
    The provider-assigned unique ID for this managed resource.
    last_update_time str
    The last update time of the Kafka trigger.
    status str
    The status of Kafka trigger.
    consumerGroup String
    The consumer group name of the message queue Kafka instance.
    creationTime String
    The creation time of the Kafka trigger.
    id String
    The provider-assigned unique ID for this managed resource.
    lastUpdateTime String
    The last update time of the Kafka trigger.
    status String
    The status of Kafka trigger.

    Look up Existing KafkaTrigger Resource

    Get an existing KafkaTrigger 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?: KafkaTriggerState, opts?: CustomResourceOptions): KafkaTrigger
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        batch_flush_duration_milliseconds: Optional[int] = None,
        batch_size: Optional[int] = None,
        consumer_group: Optional[str] = None,
        creation_time: Optional[str] = None,
        description: Optional[str] = None,
        enabled: Optional[bool] = None,
        function_id: Optional[str] = None,
        kafka_credentials: Optional[KafkaTriggerKafkaCredentialsArgs] = None,
        last_update_time: Optional[str] = None,
        maximum_retry_attempts: Optional[int] = None,
        mq_instance_id: Optional[str] = None,
        name: Optional[str] = None,
        starting_position: Optional[str] = None,
        status: Optional[str] = None,
        topic_name: Optional[str] = None) -> KafkaTrigger
    func GetKafkaTrigger(ctx *Context, name string, id IDInput, state *KafkaTriggerState, opts ...ResourceOption) (*KafkaTrigger, error)
    public static KafkaTrigger Get(string name, Input<string> id, KafkaTriggerState? state, CustomResourceOptions? opts = null)
    public static KafkaTrigger get(String name, Output<String> id, KafkaTriggerState state, CustomResourceOptions options)
    resources:  _:    type: volcengine:vefaas:KafkaTrigger    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:
    BatchFlushDurationMilliseconds int
    The maximum waiting time for batch consumption of triggers.
    BatchSize int
    The number of messages per batch consumed by the trigger in bulk.
    ConsumerGroup string
    The consumer group name of the message queue Kafka instance.
    CreationTime string
    The creation time of the Kafka trigger.
    Description string
    The description of the Kafka trigger.
    Enabled bool
    Whether to enable triggers at the same time as creating them.
    FunctionId string
    The ID of Function.
    KafkaCredentials KafkaTriggerKafkaCredentials
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    LastUpdateTime string
    The last update time of the Kafka trigger.
    MaximumRetryAttempts int
    The maximum number of retries when a function has a runtime error.
    MqInstanceId string
    The instance ID of Message queue Kafka.
    Name string
    The name of the Kafka trigger.
    StartingPosition string
    Specify the location where the messages in the Topic start to be consumed.
    Status string
    The status of Kafka trigger.
    TopicName string
    The Topic name of the message queue Kafka instance.
    BatchFlushDurationMilliseconds int
    The maximum waiting time for batch consumption of triggers.
    BatchSize int
    The number of messages per batch consumed by the trigger in bulk.
    ConsumerGroup string
    The consumer group name of the message queue Kafka instance.
    CreationTime string
    The creation time of the Kafka trigger.
    Description string
    The description of the Kafka trigger.
    Enabled bool
    Whether to enable triggers at the same time as creating them.
    FunctionId string
    The ID of Function.
    KafkaCredentials KafkaTriggerKafkaCredentialsArgs
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    LastUpdateTime string
    The last update time of the Kafka trigger.
    MaximumRetryAttempts int
    The maximum number of retries when a function has a runtime error.
    MqInstanceId string
    The instance ID of Message queue Kafka.
    Name string
    The name of the Kafka trigger.
    StartingPosition string
    Specify the location where the messages in the Topic start to be consumed.
    Status string
    The status of Kafka trigger.
    TopicName string
    The Topic name of the message queue Kafka instance.
    batchFlushDurationMilliseconds Integer
    The maximum waiting time for batch consumption of triggers.
    batchSize Integer
    The number of messages per batch consumed by the trigger in bulk.
    consumerGroup String
    The consumer group name of the message queue Kafka instance.
    creationTime String
    The creation time of the Kafka trigger.
    description String
    The description of the Kafka trigger.
    enabled Boolean
    Whether to enable triggers at the same time as creating them.
    functionId String
    The ID of Function.
    kafkaCredentials KafkaTriggerKafkaCredentials
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    lastUpdateTime String
    The last update time of the Kafka trigger.
    maximumRetryAttempts Integer
    The maximum number of retries when a function has a runtime error.
    mqInstanceId String
    The instance ID of Message queue Kafka.
    name String
    The name of the Kafka trigger.
    startingPosition String
    Specify the location where the messages in the Topic start to be consumed.
    status String
    The status of Kafka trigger.
    topicName String
    The Topic name of the message queue Kafka instance.
    batchFlushDurationMilliseconds number
    The maximum waiting time for batch consumption of triggers.
    batchSize number
    The number of messages per batch consumed by the trigger in bulk.
    consumerGroup string
    The consumer group name of the message queue Kafka instance.
    creationTime string
    The creation time of the Kafka trigger.
    description string
    The description of the Kafka trigger.
    enabled boolean
    Whether to enable triggers at the same time as creating them.
    functionId string
    The ID of Function.
    kafkaCredentials KafkaTriggerKafkaCredentials
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    lastUpdateTime string
    The last update time of the Kafka trigger.
    maximumRetryAttempts number
    The maximum number of retries when a function has a runtime error.
    mqInstanceId string
    The instance ID of Message queue Kafka.
    name string
    The name of the Kafka trigger.
    startingPosition string
    Specify the location where the messages in the Topic start to be consumed.
    status string
    The status of Kafka trigger.
    topicName string
    The Topic name of the message queue Kafka instance.
    batch_flush_duration_milliseconds int
    The maximum waiting time for batch consumption of triggers.
    batch_size int
    The number of messages per batch consumed by the trigger in bulk.
    consumer_group str
    The consumer group name of the message queue Kafka instance.
    creation_time str
    The creation time of the Kafka trigger.
    description str
    The description of the Kafka trigger.
    enabled bool
    Whether to enable triggers at the same time as creating them.
    function_id str
    The ID of Function.
    kafka_credentials KafkaTriggerKafkaCredentialsArgs
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    last_update_time str
    The last update time of the Kafka trigger.
    maximum_retry_attempts int
    The maximum number of retries when a function has a runtime error.
    mq_instance_id str
    The instance ID of Message queue Kafka.
    name str
    The name of the Kafka trigger.
    starting_position str
    Specify the location where the messages in the Topic start to be consumed.
    status str
    The status of Kafka trigger.
    topic_name str
    The Topic name of the message queue Kafka instance.
    batchFlushDurationMilliseconds Number
    The maximum waiting time for batch consumption of triggers.
    batchSize Number
    The number of messages per batch consumed by the trigger in bulk.
    consumerGroup String
    The consumer group name of the message queue Kafka instance.
    creationTime String
    The creation time of the Kafka trigger.
    description String
    The description of the Kafka trigger.
    enabled Boolean
    Whether to enable triggers at the same time as creating them.
    functionId String
    The ID of Function.
    kafkaCredentials Property Map
    Kafka identity authentication. When importing resources, this attribute will not be imported. If this attribute is set, please use lifecycle and ignore_changes ignore changes in fields.
    lastUpdateTime String
    The last update time of the Kafka trigger.
    maximumRetryAttempts Number
    The maximum number of retries when a function has a runtime error.
    mqInstanceId String
    The instance ID of Message queue Kafka.
    name String
    The name of the Kafka trigger.
    startingPosition String
    Specify the location where the messages in the Topic start to be consumed.
    status String
    The status of Kafka trigger.
    topicName String
    The Topic name of the message queue Kafka instance.

    Supporting Types

    KafkaTriggerKafkaCredentials, KafkaTriggerKafkaCredentialsArgs

    Mechanism string
    Kafka authentication mechanism.
    Password string
    The SASL/PLAIN user password set when creating a Kafka instance.
    Username string
    The SASL/PLAIN user name set when creating a Kafka instance.
    Mechanism string
    Kafka authentication mechanism.
    Password string
    The SASL/PLAIN user password set when creating a Kafka instance.
    Username string
    The SASL/PLAIN user name set when creating a Kafka instance.
    mechanism String
    Kafka authentication mechanism.
    password String
    The SASL/PLAIN user password set when creating a Kafka instance.
    username String
    The SASL/PLAIN user name set when creating a Kafka instance.
    mechanism string
    Kafka authentication mechanism.
    password string
    The SASL/PLAIN user password set when creating a Kafka instance.
    username string
    The SASL/PLAIN user name set when creating a Kafka instance.
    mechanism str
    Kafka authentication mechanism.
    password str
    The SASL/PLAIN user password set when creating a Kafka instance.
    username str
    The SASL/PLAIN user name set when creating a Kafka instance.
    mechanism String
    Kafka authentication mechanism.
    password String
    The SASL/PLAIN user password set when creating a Kafka instance.
    username String
    The SASL/PLAIN user name set when creating a Kafka instance.

    Import

    VefaasKafkaTrigger can be imported using the id, e.g.

    $ pulumi import volcengine:vefaas/kafkaTrigger:KafkaTrigger default resource_id

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

    Package Details

    Repository
    volcengine volcengine/pulumi-volcengine
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the volcengine Terraform Provider.
    volcengine logo
    Volcengine v0.0.34 published on Wednesday, Jul 2, 2025 by Volcengine
    volcengine/pulumi-volcengine