Как стать автором
Обновить
0
0
Игорь Думчиков @igor_dumchykov

Senior software engineer

Отправить сообщение
и работа из той же песочницы, к тому же бесплатная
На практике столкнулся еще с одними граблями: на основе стримов реализовать ретраи (перекинуть сообщение обратно в очередь если оно было запроцессено с ошибками) с конфигурируемым временем задержки. Штатного решения я не нашел, Thread.sleep() просто усыпил поток стримов (а потоков согласно архитектуре kafka streams выделяется пропорционально кол-ву партиций). Остановился на таком решении: закидывать все сообщения для ретраев в State Store и периодически скедулером доставать все сообщения и проверять сколько времени они там лежат, если это время >= сконфигурированного времени ретрая — перекидываем в очередь. Возможно есть более простое решение?
Помню когда сдавал сертификацию, покупал симулятор экзамена с вопросами здесь enthuware.com/index.php. Даже сейчас иногда открываю программку для проверки своих знаний. Советую!

Информация

В рейтинге
Не участвует
Откуда
Украина
Дата рождения
Зарегистрирован
Активность