DotPassar:如何设置消费者接收队列大小



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);

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

致以最良好的问候db

相关内容

  • 没有找到相关文章

最新更新