yr.SubscriptionConfig#
- class yr.SubscriptionConfig(subscription_name: str, subscriptionType: ~yr.stream.SubscriptionType = SubscriptionType.STREAM, extend_config: ~typing.Dict[str, str] = <factory>)#
基类:
object消费者订阅的配置类。
属性:
订阅类型,包括
STREAM,ROUND_ROBIN和KEY_PARTITIONS。订阅名,用于标识生产者配置中的订阅。
扩展配置。
方法: