А зачем вообще kstream?

то есть это просто сахар над пропуском получаемых консьюмером сообщений? Или тут оффсет не сдвигается? Т.е. как это реализовано, какие внутри гарантии и производительность?

0

08.01.2021

Vik Gamov

Phil Delgyado
то есть это просто сахар над пропуском получаемых ...

а как ещё? Кафка это immutable log, не ESB

0

08.01.2021

Vik Gamov

Phil Delgyado
то есть это просто сахар над пропуском получаемых ...

Оффсет будет свой так как это будет отдельная consumer group

0

08.01.2021

Sergey Sokolov · Accepted Answer

Sergey Sokolov

фильтрация сообщений в топике делается оч просто с помощью стримов KStream<String, String> source = builder.stream("book-created"); KStream<String, String> filtered = source.filter((key, val) -> key.equals(correlationId)); filtered.foreach((key,value)->{ System.out.println(value); });

0

08.01.2021

52 похожих чатов

А зачем вообще kstream?

8 ответов

Похожие вопросы