Skip to main content
Version: Beta 🚧

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 (Union[Dict[str, str], NoneType]) - 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

Was this page helpful?