Apache Pulsar - подтверждение от другого потока

Я раскрутил потребитель Pulsar Java в потоке T1 и передаю сообщения для обработки в поток T2.

Безопасно ли подтверждать сообщения от T2? Конкретно звонит consumer.acknowledge(messageId) в случае совместного использования двух потоков хорошо?

1 ответ

Да, Java-клиент является потокобезопасным, поэтому взаимодействие, которое вы описали, должно быть в порядке.

Другие вопросы по тегам