Комментарии 9
Подскажите пульсар умеет такое?
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 сообщение раз в 1 минуту
спасибо.
Мне кажется ни кафка, ни пульсар не должны уметь в агрегацию. Для этого на выходе надо прикручивать Flink или, на худой конец, spark
полнейшая помойка . ждем пока ктонибудь напишет статью по моим 4 пунктам которые не нашли в pulsar но есть в кафке. Ждем "Еще 5 причин выбрать Apache Kafka вместо Apache Pulsar"
2). Аналог Kafka streams в пульсаре - это Pulsar function (https://pulsar.apache.org/docs/en/functions-overview/)
Скажите, даунтаймы при ребалансировке насколько критичны - в Kafka с этим есть проблемы
Еще 5 причин выбрать Apache Pulsar вместо Apache Kafka