I've spun up a Pulsar Java consumer in thread T1 and I'm handing over the messages for processing to thread T2.
Is it safe to acknowledge messages from T2? Specifically, is calling consumer.acknowledge(messageId)
on the instance shared between two threads ok?
Yes, the java client is thread safe, so the interaction you described should be fine.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With