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__(...)
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 arekafka.ssl.endpoint.identification.algorithm
,kafka.security.protocol
,kafka.sasl.mechanism
, andkafka.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
)