使用Pulsar消息队列,消费者客户端一般需要配置哪些参数?

提问者:帅平 问题分类:消息队列
使用Pulsar消息队列,消费者客户端一般需要配置哪些参数?
1 个回答
箫声断ツ何处莫凭栏
箫声断ツ何处莫凭栏
消费者涉及到的配置参数有:
receiverQueueSize: 消费者接收队列大小,影响消费速度和内存使用。
subscriptionType: 订阅类型(Exclusive、Shared、Failover、Key_Shared等),根据消费模式选择。
negativeAckRedeliveryDelayMs: 负面确认后重新投递消息的延迟。
ackTimeoutMillis: 自动ACK超时时间,影响消息确认策略。
numIOThreads: 设置 Netty 工作线程数,一般根据 CPU 核心数进行调整。
numWorkerThreads: 设置 Pulsar 内部工作线程数,用于处理非 I/O 密集型任务。
MaxTotalReceiverQueueSizeAcrossPartitions:该参数指定了消费者在所有分区上允许的最大接收队列大小。增加该值可以提高消费者的并发性能,但同时也会增加内存的消耗。默认值为50000。
MaxPendingChuckedMessage:该参数指定了消费者允许等待确认的分块消息数量。增加该值可以提高消费者的并发性能,但同时也会增加内存的消耗。默认值为1000。
发布于:1个月前 (04-11) IP属地:四川省
我来回答