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