Skip to main content
Version: 0.6



Configuration used for a Kafka output stream.


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



Method generated by attrs for class KafkaOutputStream.


  • kafka_bootstrap_servers (str) – The list of bootstrap servers for your Kafka brokers, e.g: “,”.

  • 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. 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?

Happy React is loading...