Apache Pulsar - 从不同的线程确认

Question

我已经在线程 T1 中启动了一个 Pulsar Java 消费者，并且我正在将要处理的消息移交给线程 T2。

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

Answer 1

是的，java客户端是线程安全的，所以你描述的交互应该没问题。