nodes/generated

Interface KafkaNodeParameters

interface KafkaNodeParameters {
    eventName?: string;
    headerParametersJson?: string;
    headersUi?: {
        headerValues: { key?: string; value?: string }[];
    };
    jsonParameters?: boolean;
    key?: string;
    message?: string;
    options?: {
        acks?: boolean;
        compression?: boolean;
        timeout?: number;
    };
    schemaRegistryUrl?: string;
    sendInputData?: boolean;
    topic?: string;
    useKey?: boolean;
    useSchemaRegistry?: boolean;
}

Properties§

readonly eventName?: string

Namespace and Name of Schema in Schema Registry (namespace.name)

readonly headerParametersJson?: string

Header parameters as JSON (flat object)

readonly headersUi?: { headerValues: { key?: string; value?: string }[] }

Default: {} Type options: {"multipleValues":true}

readonly jsonParameters?: boolean

readonly key?: string

The message key

readonly message?: string

The message to be sent

readonly options?: { acks?: boolean; compression?: boolean; timeout?: number }

Default: {}

readonly schemaRegistryUrl?: string

URL of the schema registry

readonly sendInputData?: boolean

Whether to send the data the node receives as JSON to Kafka Default: true

readonly topic?: string

Name of the queue of topic to publish to

readonly useKey?: boolean

Whether to use a message key

readonly useSchemaRegistry?: boolean

Whether to use Confluent Schema Registry