Apache Pulsar - подтверждение от другого потока
Я раскрутил потребитель Pulsar Java в потоке T1 и передаю сообщения для обработки в поток T2.
Безопасно ли подтверждать сообщения от T2? Конкретно звонит consumer.acknowledge(messageId)
в случае совместного использования двух потоков хорошо?
1 ответ
Да, Java-клиент является потокобезопасным, поэтому взаимодействие, которое вы описали, должно быть в порядке.