DotPulsar:如何设置消费者接收队列大小?
Posted
技术标签:
【中文标题】DotPulsar:如何设置消费者接收队列大小?【英文标题】:DotPulsar :How to set consumer receiveQueue Size? 【发布时间】: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);
【问题讨论】:
【参考方案1】:查看 IConsumerBuilder 和 IReaderBuilder 上的“MessagePrefetchCount”(“将预取的消息数。默认值为 1000”)。
最好的问候 分贝
【讨论】:
以上是关于DotPulsar:如何设置消费者接收队列大小?的主要内容,如果未能解决你的问题,请参考以下文章
Spring AMQP 使用 noLocal 消费者使用临时队列发送和接收