The current implementation uses consumer.acknowledge(pMsg) which is synchronous and blocks on each individual message acknowledgment, waiting for the Pulsar broker to respond. This creates a performance bottleneck as it processes acks sequentially in a loop. Should switch to consumer.acknowledgeAsync(messageIds)