TS
короче, как и сказал выше @tony_brewerio, самая нормальная реализация это reactivex/Flowable#buffer
Size: a a a
2021 November 25
TS
остальные варианты — это велосипеды
SS
почему бы тогда механизмами кафки и не воспользоваться. и вычитывать batch'ами. через KStream можно вроде сделать
SS
ES
Ну у меня есть бизнес логика, и мы ее придерживаемся
M
с самого начала
ES
Вот да, точно😁 забыл
TS
кстати, задача еще осложняется тем, что нельзя делать ACK для сообщений, которые еще не положил в CH
TS
так что да, лучше это делать прямо у источника, то бишь у Кафки
К
а сами написать не пробовали ?
К
мне кажется не прям такая сложная штука
SS
в топике у консюмера или counsumer group можно офсет поправить ручками
TS
ну лучше мануал АКК делать
TS
мне кажется
ES
Был бы у меня стримминг данных, без проблем бы Кафка консюмер для клика поставил, но, у меня не стримминг данных
SS
ну а если вычитывать сообщения из кафки и хранить их в каком то списке в хипе, это не персистентно. и если JVM упадет или будет ребут, сообщения потеряются
TS
а АККать сообщения нужно? или пофиг?
ES
Ну по идее то что прочитал, надо пометить как прочитаное то
TS
ну ты скинь хотя бы интерфейс того, как ты получаешь сообщения и как их АККаешь. можно сделать довольно простой велосипед
ES
Но сейчас это спринг делает за нас, а так придется ещё тут оборачивать это дело