h
какую практическую цель преследуешь?
Не обрабатывать событие в подписчике два раза, а только строго один.
Size: a a a
2020 April 12
ИФ
А что за ситуация, что тебе более одного раза обрабатывать приходится?
h
А что за ситуация, что тебе более одного раза обрабатывать приходится?
Упал подписчик до ack для кафки, но уже после записи в бд. В результате будет повтор и от кафки и подпичик запшет второй раз в бд, а мне это не нужно
h
Бизнес операция по своей сути НЕ идемподентна, поэтому нельзя два раза делать запись.
ИФ
ну чекай по офсету.
ИФ
ну или делай больше подписчиков
h
ну чекай по офсету.
Мне было интересно узнать именно опыт людей, кто такое уже делал.
Так вцелом одно решение я уже описал, это как раз атомарная запись оффсета вместе с результатом
Так вцелом одно решение я уже описал, это как раз атомарная запись оффсета вместе с результатом
VG
humanoid
Мне было интересно узнать именно опыт людей, кто такое уже делал.
Так вцелом одно решение я уже описал, это как раз атомарная запись оффсета вместе с результатом
Так вцелом одно решение я уже описал, это как раз атомарная запись оффсета вместе с результатом
Не надо писать и в кафку и в базу. Кафка умеет атомарного оффсет с результатом писать. А если надо сохранять с базу старой про Outbox
h
Не надо писать и в кафку и в базу. Кафка умеет атомарного оффсет с результатом писать. А если надо сохранять с базу старой про Outbox
Я не пишу и в кафку и в базу. У меня из кафки приходит сообщение, и мне его нужно обработать и результат обработку записать в базу. Но сделать это только один раз.
ИФ
humanoid
Я не пишу и в кафку и в базу. У меня из кафки приходит сообщение, и мне его нужно обработать и результат обработку записать в базу. Но сделать это только один раз.
Дык может делать коммит после обработки сообщения?
h
Дык может делать коммит после обработки сообщения?
Тогда сообщение может вообще не обработаться, если упадет до коммита и после ack для кафки
ИФ
Так поднимай количество подписчиков
h
Вот аргументы, и я соглаен
https://medium.com/serialized-io/apache-kafka-is-not-for-event-sourcing-81735c3cf5c
https://medium.com/serialized-io/apache-kafka-is-not-for-event-sourcing-81735c3cf5c