yr.SubscriptionConfig

class yr.SubscriptionConfig(subscription_name: str, subscriptionType: ~yr.stream.SubscriptionType = SubscriptionType.STREAM, extend_config: ~typing.Dict[str, str] = <factory>)

Bases: object

The configuration class subscribed by consumers.

Attributes

subscriptionType	Subscription type, including STREAM, ROUND_ROBIN, and KEY_PARTITIONS.
subscription_name	Subscription name, used to identify subscriptions in the producer configuration.
extend_config	Extended configuration.

Methods

__init__