Skip to main content
Version: Beta 🚧

tecton.KafkaOutputStream

Summary​

Configuration used for a Kafka output stream.

Attributes​

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

Methods​

__init__(...)​

Method generated by attrs for class KafkaOutputStream.

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)

Was this page helpful?

🧠 Hi! Ask me anything about Tecton!

Floating button icon