nodes/generated

Interface KafkaNodeParameters

Source
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?: { ... }

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

§readonly jsonParameters?: boolean
§readonly key?: string

The message key

§readonly message?: string

The message to be sent

§readonly options?: { ... }

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