при инициализации создаст новый поток для фоновой отправки в брокер сообщений.
Очередь для отправки в брокер будет наполняться в одном потоке с приложением. Но вот сама отправка в брокер должна быть в другом потоке (отправка в фоновом режиме).
То есть я хочу, чтобы мы наполняли очередь по мере выполнения в программы, а отправка из очереди в брокер была в фоновом режиме.
Подскажите, пожалуйста, как мне поступиться к этому?
Мне кажется ты путаешь пхп с го, нодой или питоном
Спасибо за мнение
Ну в пхп делают отдельный воркер который разгребает очередь
А что значит воркер?
По сути запускают отдельный процесс-демон который в цикле проверяет очередь и уже сообщения из неё обрабатывает
А проверяет в течение всего запроса?
Воркер висит всегда и слушает очередь. Запрос накидывает сообщения в очередь (и не один запрос, их много), а воркер эту очередь неспеша разгребает
Мне кажется это по CPU затратно, не?
Нет, есть блокирующее чтение, оно не затратно
https://docs.confluent.io/platform/current/kafka-rest/index.html
Обсуждают сегодня