Комментарии 2
напомню из соседней темы что нету в пульсаре для хайлоуда
1) на конкретное сообщение сказать "сейчас нет, повторить через 5 минут" , как это умеет Azure Service Bus ? ps. без принятия, и повторного забрасывания клона сообщения уже с delay в очередь.
2) есть ли в пульсар аналог ktable и можно ли делать join в новый ktable на основе двух других ktable?
3) может ли пульсар при оконной агрегации записывать только финальных результат окна ? а не как сейчас в кафке , если заселектить результирующий топик окна, то там будут все изменения, а не только финальные.
4) если хочу записывать из пульсара в db их фичей из коробки. Если такая возможность как отправка только финальной (сейчас поясни ниже) данных чтобы не убить db при супер изменяемых параметрах?
например в пульсаре будет супер изменяемая метрика колво кликов от всех пользователей от сайта , каждый клик = 1 сообщение и мы делаем по этому топику инкремент
в топике будет:
count: 500
count: 501
count: 502
В секунде допустим будут млны записей, так вот если их все пульсар будет слать в базу ,1) то DB умрет 2) это бессмысленно если нам не важен реалтайм.
Хотел уточнить - по п1. описание механизма Retry https://pulsar.apache.org/docs/2.11.x/concepts-messaging/#retry-letter-topic подходит под описанный сценарий использования?
7 причин, по которым мы предпочли Apache Pulsar Apache Kafka