Apache Pulsar - 从不同的线程承认

Question

我已经在线程T1中启动了一个Pulsar Java消费者,我正在将消息传递给线程T2进行处理.

确认来自T2的消息是否安全？具体来说,是调用consumer.acknowledge(messageId)两个线程之间共享的实例吗？

Answer 1

是的，Java客户端是线程安全的，因此您描述的交互应该很好。