All streams
Search
Write a publication
Pull to refresh
0
0
Игорь Думчиков @igor_dumchykov

Senior software engineer

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

Information

Rating
Does not participate
Location
Украина
Date of birth
Registered
Activity