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