【问题标题】:DotPulsar :How to set consumer receiveQueue Size?DotPulsar:如何设置消费者接收队列大小?
【发布时间】:2021-09-17 22:06:28
【问题描述】:

Pulsar .Net SDK -DotPulsar 如何设置消费者接收队列大小? 等待使用 var consumer = client1.NewConsumer(Schema.String) .StateChangedHandler(监视器) .ConsumerName(consurName) .SubscriptionName("Forward-Sub3") .SubscriptionType(SubscriptionType.Shared) .Topic(myTopic) .create();

        Console.WriteLine("Press Ctrl+C to exit");

        await ConsumeMessages(consumer, cts.Token);

【问题讨论】:

    标签: c# sdk message .net-5 apache-pulsar


    【解决方案1】:

    查看 IConsumerBuilder 和 IReaderBuilder 上的“MessagePrefetchCount”(“将预取的消息数。默认值为 1000”)。

    最好的问候 分贝

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2018-01-28
      • 2012-07-14
      • 1970-01-01
      • 2011-10-24
      • 2017-11-17
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多