GitHub user filthz edited a comment on the discussion: recycled already - exception
Just checked the versions: pulsar-client-admin-api:3.1.1 pulsar-client-api:3.1.1 pulsar-client-original:3.1.1 pulsar-common:3.1.1 Netty:  Consumer config: ` @EventListener(ApplicationReadyEvent.class) public void init() { for(int i = 0; i < parallelConsumer; i++) { pulsarClient.newConsumer() .topic(activityTopic) .subscriptionName(lastActiveSub) .consumerName(consumerName + "_" + randomString(8)) .subscriptionType(SubscriptionType.Key_Shared) .enableBatchIndexAcknowledgment(true) .subscriptionInitialPosition(SubscriptionInitialPosition.Latest) .keySharedPolicy(KeySharedPolicy.autoSplitHashRange()) .messageListener(this::messageListener) .startPaused(false) .negativeAckRedeliveryBackoff(MultiplierRedeliveryBackoff.builder() .minDelayMs(1000) .maxDelayMs(60 * 1000) .multiplier(2) .build()) .ackTimeout(5, TimeUnit.MINUTES) .subscribeAsync(); } }` I am not able to reproduce as it is occurring randomly on production where we have quite a lot of messages GitHub link: https://github.com/apache/pulsar/discussions/21929#discussioncomment-8192159 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
