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 = None The list of bootstrap servers for your Kafka brokers, e.g: "abc.xyz.com:xxxx,abc2.xyz.com:xxxx".
• topics: str = None A comma-separated list of Kafka topics the record will be appended to. Currently only supports one topic.
• options: Optional[Dict[str, str]] = None A map of additional Spark readStream options. Only roleArn is supported at the moment.
• include_features: bool = False Return feature values in addition to entity keys. Not supported for window aggregate Feature Views.