Interface KafkaStreamConfig

Kafka-specific configuration for a Stream.

interface KafkaStreamConfig {
extraOptions?: Record<string, string>;
subscriptionMode?: KafkaSubscriptionMode;
}

Properties

extraOptions?: Record<string, string>

Optional Kafka source or consumer options, validated against a server-side allowlist at request time. Allowed keys:

maxOffsetsPerTrigger
startingOffsets
includeHeaders
kafka.request.timeout.ms
kafka.session.timeout.ms
kafka.max.partition.fetch.bytes The following keys are ingestion-only and are stripped before being forwarded to the materialization pipeline:
maxOffsetsPerTrigger
startingOffsets Auth and connection details belong on the parent Stream's connection_config, not here.

Options to configure which Kafka topics to pull data from.