AB
Size: a a a
2020 March 10
AB
У меня ситуация такая: нужно построить event sourcing на агрегате, при том порядок важен. Для того чтобы обеспечить порядок буду писать все сообщения связанные с агрегатом в один топик и в одну партицию по хешу. Только вопрос в том как в этом топике понимать как обрабатывать тот или иной ивент
AB
Я рекомендую поглядеть еще на avro. В этом случае не надо заморачиваться с заголовками потому что schema id пишется в payload, а схема раздаётся через schema registry
Avro вроде как не эту проблему призвана решать, а то чтобы люди могли использовать ивенты без коммуникации
AB
Andriy Bashuk
Avro вроде как не эту проблему призвана решать, а то чтобы люди могли использовать ивенты без коммуникации
Это как API документация типа SWAGGER, только еще и позволяет менять во времени схему. Так же? Но это не инструмент для решения конкретно моей проблемы. Я видел в интернете статьи о том, что если у меня сообщения связаны с определенным агрегатом, то все они должны идти через один топик
VG
Andriy Bashuk
Avro вроде как не эту проблему призвана решать, а то чтобы люди могли использовать ивенты без коммуникации
AB
EI
не знаю, а что-то про acknowledge слышали в kafka? я так понял можно как-то сделать так, чтоб message kafka посылался только тогда,
когда завершится транзакция с базой.
когда завершится транзакция с базой.
То что вы хотите, как мне кажется покрывается тем, что я посоветовал. Вот пример кода: https://stackoverflow.com/a/15026797/898588 Другое дело, что если вы не сможете записать в кафку, то транзакция БД уже не откатится.
IR
не знаю, а что-то про acknowledge слышали в kafka? я так понял можно как-то сделать так, чтоб message kafka посылался только тогда,
когда завершится транзакция с базой.
когда завершится транзакция с базой.
пока размышляешь уже бы написал outbox
IR
я прикинул там то писать
S🕶
попробовал другие варианты на подобии этого, не заработало https://stackoverflow.com/questions/53432209/no-transaction-is-in-process-with-spring-kafka-using-replyingkafkatemplate-k , только время потерял
λ
попробовал другие варианты на подобии этого, не заработало https://stackoverflow.com/questions/53432209/no-transaction-is-in-process-with-spring-kafka-using-replyingkafkatemplate-k , только время потерял
не время потерял а получил новый опыт