yr.SubscriptionConfig

yr.SubscriptionConfig#

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

基类:object

消费者订阅的配置类。

属性

subscriptionType

订阅类型,包括 STREAMROUND_ROBINKEY_PARTITIONS

subscription_name

订阅名,用于标识生产者配置中的订阅。

extend_config

扩展配置。

方法