Interface KafkaTriggerNodeParameters

Source

interface KafkaTriggerNodeParameters {
    groupId?: string;
    options?: {
        allowAutoTopicCreation?: boolean;
        autoCommitInterval?: number;
        autoCommitThreshold?: number;
        fromBeginning?: boolean;
        heartbeatInterval?: number;
        jsonParseMessage?: boolean;
        maxInFlightRequests?: number;
        onlyMessage?: boolean;
        parallelProcessing?: boolean;
        returnHeaders?: boolean;
        sessionTimeout?: number;
    };
    schemaRegistryUrl?: string;
    topic?: string;
    useSchemaRegistry?: boolean;
}