black_ei

使用 KeyAffinityExecutor.newSerializingExecutor(IntSupplier parallelism, IntSupplier queueBufferSize, String threadName) 返回的对象 没有设置并发参数方法 然后我尝试创建一个 KeyAffinityExecutorBuilder affinityExecutor = KeyAffinityExecutor.newKeyAffinityExecutor(); affinityExecutor.parallelism(this.mqttProperties::getConsumer) .executor(KeyAffinityExecutorUtils.executor("mqtt-async-service-%d", () -> this.mqttProperties.getBlockingQueue())) .usingRandom(it -> it > RANDOM_THRESHOLD) .build(); 可KeyAffinityExecutorUtils.executor方法是defalut 我无法使用 ,