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”.

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

• options (Optional[Dict[str, str]]) – A map of additional Spark readStream options. Some example options are kafka.ssl.endpoint.identification.algorithm, kafka.security.protocol, kafka.sasl.mechanism, and kafka.sasl.jaas.config (Default: None)

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