import * as pulumi from "@pulumi/pulumi"; import * as outputs from "../types/output"; /** * Data Source schema for Volcengine::VEFAAS::KafkaTrigger */ export declare function getKafkaTrigger(args: GetKafkaTriggerArgs, opts?: pulumi.InvokeOptions): Promise; /** * A collection of arguments for invoking getKafkaTrigger. */ export interface GetKafkaTriggerArgs { /** * Uniquely identifies the resource. */ id: string; } /** * A collection of values returned by getKafkaTrigger. */ export interface GetKafkaTriggerResult { /** * Maximum wait time for batch consumption by the trigger. Unit: milliseconds (ms). Valid range: 1000–60000 ms. Default: 1000 ms. */ readonly batchFlushDurationMilliseconds: number; /** * Number of messages per batch for trigger batch consumption. */ readonly batchSize: number; /** * Consumer group name of the Kafka message queue instance. */ readonly consumerGroup: string; /** * Kafka trigger creation time. */ readonly createdTime: string; /** * Description of the Kafka trigger. Limited to 200 characters. */ readonly description: string; /** * Enable the trigger when creating it. Options: true—enable. false—disable. */ readonly enabled: boolean; /** * Function ID. */ readonly functionId: string; /** * Uniquely identifies the resource. */ readonly id: string; /** * Kafka identity authentication. Function service uses Kafka ACL permission policies to authenticate message consumption for SASL users of types PLAIN and SCRAM-SHA-256. */ readonly kafkaCredentials: outputs.vefaas.GetKafkaTriggerKafkaCredentials; /** * Kafka trigger ID. */ readonly kafkaTriggerId: string; /** * Maximum number of retries when the function encounters a runtime error (including user code errors and runtime errors). Valid values: positive integers from 0 to 100. */ readonly maximumRetryAttempts: number; /** * Kafka message queue instance ID. */ readonly mqInstanceId: string; /** * Kafka trigger name. Trigger names must be unique within the same function. Only uppercase and lowercase letters, numbers, and underscores are allowed, must start with a letter, and be 4–63 characters long. */ readonly name: string; /** * Specify the starting position for consuming messages in the Topic. Options: Latest—consume only messages produced after subscribing to the Topic. Earliest—consume from the first message produced in the Topic. */ readonly startingPosition: string; /** * Kafka trigger status. Parameter values: ready—running, failed—failed, pending—starting. */ readonly status: string; /** * Topic name of the Kafka message queue instance. */ readonly topicName: string; /** * Last update time of the Kafka trigger. */ readonly updatedTime: string; } /** * Data Source schema for Volcengine::VEFAAS::KafkaTrigger */ export declare function getKafkaTriggerOutput(args: GetKafkaTriggerOutputArgs, opts?: pulumi.InvokeOutputOptions): pulumi.Output; /** * A collection of arguments for invoking getKafkaTrigger. */ export interface GetKafkaTriggerOutputArgs { /** * Uniquely identifies the resource. */ id: pulumi.Input; }