我在线程中创建了一个Pulsar Java消费程序 我把要处理的消息交给线程 T2级 .
T2级 ? 具体来说,就是打电话 consumer.acknowledge(messageId) 在两个线程之间共享的实例上,可以吗?
consumer.acknowledge(messageId)
是的,java客户机是线程安全的,所以您描述的交互应该是良好的。