KafkaOutputStream

Summary

Configuration used for a Kafka output stream.

Attributes

The attributes are the same as the __init__ method parameters. See below.

Methods

__init__(...)

Parameters

• kafka_bootstrap_servers (str) - The list of bootstrap servers for your Kafka brokers, e.g: "abc.xyz.com:xxxx,abc2.xyz.com:xxxx". Default: None


• topics (str) - A comma-separated list of Kafka topics the record will be appended to. Currently only supports one topic. Default: None


• options (Optional[Dict[str, str]]) - A map of additional Spark readStream options. Only roleArn is supported at the moment. Default: None


• include_features (bool) - Return feature values in addition to entity keys. Not supported for window aggregate Feature Views. Default: false