PD
так а если отправитель не живой
А тогда те же проблемы будут и с кафкой, если кластер не принимает сообщения (например выбирает лидера)
Size: a a a
2020 December 10
PD
Тут надо оркестратор с гарантиями делать. Или персистентные акторы или cadence-style или саги
IP
5 лет назад
с#
5 лет назад
я смотрю всякие штуки от релиза в 16 году
IP
ну и структура файлов не имеет значения. чекай build.gradle, если хочешь ковыряться в окаменелостях
с#
ну и структура файлов не имеет значения. чекай build.gradle, если хочешь ковыряться в окаменелостях
так я конечно знаю, что не имеет, там вообще pom.xml
IP
так я конечно знаю, что не имеет, там вообще pom.xml
вообще говоря, ты даже в современном плагине можешь сделать сорцсеты с такими названиями
с#
вообще говоря, ты даже в современном плагине можешь сделать сорцсеты с такими названиями
да, у меня также, ток web, desktop, android, ios
OY
на счёт дискуссии сверху про кафку, http/2 и тд
гляньте на rsocket + resumability + load balancing
это сейчас заимплеменчено только в rsocket-java пока что, но если оно будет нужно, можно поконтребьютить в rsocket-kotlin
потому что выглядит как то, что нужно :)
гляньте на rsocket + resumability + load balancing
это сейчас заимплеменчено только в rsocket-java пока что, но если оно будет нужно, можно поконтребьютить в rsocket-kotlin
потому что выглядит как то, что нужно :)
AN
Ну, с гарантией отправки всегда сложно, если кластер недоступен и умирает сервис-продьюсер...
гарантия доставки. Если отправитель умер - то это все.
AN
Ну, если получатель не живой, то отправитель может повторить вызов.
Вы попробуйте сделать систему, которая проверяла бы доставку, хранила на отправителе лишний буффер и перепосылала бы это все. Это кормар. И лучше так не делать.
AN
5 лет назад
два
PD
Вы попробуйте сделать систему, которая проверяла бы доставку, хранила на отправителе лишний буффер и перепосылала бы это все. Это кормар. И лучше так не делать.
Ну, Кафковский клиент так и делает. Но все равно не надёжно же
PD
на счёт дискуссии сверху про кафку, http/2 и тд
гляньте на rsocket + resumability + load balancing
это сейчас заимплеменчено только в rsocket-java пока что, но если оно будет нужно, можно поконтребьютить в rsocket-kotlin
потому что выглядит как то, что нужно :)
гляньте на rsocket + resumability + load balancing
это сейчас заимплеменчено только в rsocket-java пока что, но если оно будет нужно, можно поконтребьютить в rsocket-kotlin
потому что выглядит как то, что нужно :)
А зачем? Что это даст кроме багов?
AN
Ну, Кафковский клиент так и делает. Но все равно не надёжно же
Я к тому, что руками это просто не сделаешь. Поэтому мне интересно посмотреть, как и что умеет кафка
PD
Ну, тут скорее про клиент Кафки.
Самое надёжное - это в рамках транзакции писать события в БД, а из нее отравлять через кафку или уже пофиг как. Но сложно и не быстро.
Самое надёжное - это в рамках транзакции писать события в БД, а из нее отравлять через кафку или уже пофиг как. Но сложно и не быстро.
AN
Ну, тут скорее про клиент Кафки.
Самое надёжное - это в рамках транзакции писать события в БД, а из нее отравлять через кафку или уже пофиг как. Но сложно и не быстро.
Самое надёжное - это в рамках транзакции писать события в БД, а из нее отравлять через кафку или уже пофиг как. Но сложно и не быстро.
Какая БД в распределенной системе? До БД надо еще доставить.
PD
Спринговый при штатном отключении умеет ждать освобождения буфера.
PD
Какая БД в распределенной системе? До БД надо еще доставить.
Ну, acid distributed db вполне есть
AN
Речь не о вебе вообще. На нем свет клином не сошелся