Open noBUgm opened 11 months ago
consumer, err := c.cli.Subscribe(pulsar.ConsumerOptions{ Topic: config.Topic, SubscriptionName: subscriptionName(config.Topic), Type: pulsar.Failover, }) ConsumerOptions的参数是否可以改成可配置的，通过业务传入，如果没有传入则用默认处理方式，如果传入了，则用传入的进行接受。因为测试环境比较多，需要多个topic进行订阅处理。
consumer, err := c.cli.Subscribe(pulsar.ConsumerOptions{ Topic: config.Topic, SubscriptionName: subscriptionName(config.Topic), Type: pulsar.Failover, })
consumer, err := c.cli.Subscribe(pulsar.ConsumerOptions{ Topic: config.Topic, SubscriptionName: subscriptionName(config.Topic), Type: pulsar.Failover, })ConsumerOptions的参数是否可以改成可配置的，通过业务传入，如果没有传入则用默认处理方式，如果传入了，则用传入的进行接受。因为测试环境比较多，需要多个topic进行订阅处理。