Как стать автором
Обновить

Комментарии 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"

НЛО прилетело и опубликовало эту надпись здесь

Kafka streams - это тоже не rocket since +- тоже самое по факту.

И что плохого в том что работает на броекре, а не на клиенте? ИМХО, так даже быстрее, поскольку убирается прокачка данных на клиент.

Скажите, даунтаймы при ребалансировке насколько критичны - в Kafka с этим есть проблемы

НЛО прилетело и опубликовало эту надпись здесь
Зарегистрируйтесь на Хабре, чтобы оставить комментарий

Публикации

Истории