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