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:如何设置消费者接收队列大小?的主要内容,如果未能解决你的问题,请参考以下文章

RabbitMQ 如何实现对同一个应用的多个节点进行广播

RabbitMQ怎样能实现多个队列由一个消费者来接收消息

Spring AMQP 使用 noLocal 消费者使用临时队列发送和接收

python使用rabbitMQ介绍三(发布订阅模式)

Spring AMQP使用noLocal使用者发送和接收临时队列

什么是阻塞队列?阻塞队列的实现原理是什么?如何使用 阻塞队列来实现生产者-消费者模型?