Interface KafkaSource

interface KafkaSource {
filterCondition?: string;
name?: string;
}

Properties

filterCondition?: string

The filter condition applied to the source data before aggregation.

name?: string

Name of the Kafka source, used to identify it. This is used to look up the corresponding KafkaConfig object. Can be distinct from topic name.