Видео

Сергей, у Вас нет в планах сделать видео с разбором популярных и нетривиальных операторов Project Reator ? Как бы это было бы круто 🥺

Вопрос по коду. Создание KafkaReceiver (класс ReactiveReceiver) KafkaReceiver.create(options) .receiveAutoAck() .concatMap(consumerRecordFlux -> { log.info("consumerRecordFlux done, commit"); return consumerRecordFlux; }) .retryWhen(Retry.backoff(3, Duration.of(10L, ChronoUnit.SECONDS))); 1. Почему выбран метод concatMap? Какая его логика? Мы могли бы использовать например doOnNext для логирования очередного элемента потока. 2. Почему используется backoff в retryWhen, а не fixedDelay например?

+

Отличное объяснение!! Спасибо.

Спасибо! Стало быть, у Micronaut Reactor под капотом? Или его надо специально подключать?

Очень похоже на Spring Boot c WebFlux )) но я не увидел ни одной причины зачем использовать Micronaut вместо SpringBoot

Спасибо за просветительскую работу!

Спасибо!!!!!!

Спасибо!

Спасибо!

Спасибо! Понятное объяснение. Было очень интересно)

Сергей, огромное спасибо за видео! Как всегда всё познавательно и внятно, как на курсах)

Спасибо, интересно и полезно. Пример со Спринг Бута тоже было бы классно вместе посмотреть)

Сори, не смог до конца досмотреть, такое монотонное объяснение, тяжело очень для восприятия, несколько раз перематывал, так как терял логическую цепочку, что происходит. Ужасное объяснение, хотя структура прекрасная абсолютно

Жду шестую серию сериала)

Я думаю, что стоило хоть разок запустить приложение и показать как оно работает)))

Интересно, но к сожалению "плохой звук": через наушники слышно нормально, а вот на средних динамиках не слышно.

Спасибо. Без базы данных нельзя обойтись?.. Это же потеря скорости.

Классный проект (особенно порадовал production-ready подход к разработке). Очень интересно будет следить за его развитием в полноценную систему. Такие видеосериалы с постепенным построением готовой неучебной платформы, на мой взгляд, как раз лучшие для обучения начинающего: позволяют понять для чего каждый элемент и чем отличаются подходы P.S. кстати, не понял, почему в качестве мапперов для таких объемных дто не использовался mapstruct, он легковесный и одной строкой заменяет все эти полотна кода?

Хорошее видео, спасибо :) Нет ли в планах создания полноценного курса по какой-либо из тем? Или если есть может кто-то сказать название и где можно приобрести?

Спасибо. Посмотрел позже. Было интересно и полезно.

Отличное видео, пересмотрел второй раз спустя время и всё понял. Замечательный пример про бармена. Пожалуйста, продолжайте использовать такие бытовые примеры для объяснения - очень хорошо запоминается.

Спасибо, отличное видео!

Петрелевич очень умный парень, хорошо доносит

Очень хорошо объяснили ! Спасибо !

Если guava есть в classpath, то по какой причине libApiUse ее не видит?

Из разряда "как нарисовать сову": 1. рисуем три кружка; 2. дорисовываем до совы. Отус такой ценник за свои курсы лупит, а лайф-кодинг поленился сделать даже на вводном уроке. Смотрите - это парсер, ну парсер и парсер, ничего особенного 😅 Спринг так же объясняете?) Это бин, ну бин и бин, ничего особенного, поехали дальше))

Спасибо большое за видео! Очень познавательно

откуда при раскладе 3 сек на источник и 2 сек на обработчик может возникнуть очередь? источник генерит медленнее чем обработчик обрабатывает. 1,2,3 источник 4,5 обработчик 4,5,6 источник 7,8 обработчик 7,8,9 источник

спасибо очень информативно, только вот вопрос, как скажем из CI задать выбор энва? Определить две configMap и как-то выбирать между ними или же как-то по другому ?

Спасибо!

Сергей, спасибо за то, что предоставили исходный код) Это очень важно для новичков)

Спасибо огромное) шикарное видео! Честно говоря, не помню чтобы встречал разорванное текстовое сообщение. Насколько знаю, текстовые сообщения передаются по протоколу TCP, а этот протокол должен ГАРАНТИРОВАТЬ целостность отправленных пакетов.

Спасибо! Довольно познавательный цикл получился. Не так давно, нечто подобное у себя на проекте реализовывали с командой. За идею с применением концепции конечных автоматов в кейсе с парсингом, прям большой респект!

Вопрос к Сергею, не первый раз уже слышу его мысль о важности groupID для консьюмера, т.е. если скопировать код из другого проекта и не изменить имя группы, то он (консьюмер) будет "красть" не свои сообщения. И вот тут у меня непонятки: ведь мы при настройке консюмера указываем еще и имя топика, на который он подписан. Я так понимал, для того чтобы он забирал по ошибке сообщения из другого проекта, нужно чтобы и имя группы, и имя топика совпало, а это еще более малый шанс

Смущает фраза из доки "that max.poll.records does not impact the underlying fetching behavior". Т.е. звучит так, что сетевые запросы - это одно, а poll() - другое, и на сетевые запросы к кафке настройка не влияет. Т.е. запрошенный объем данных где-то еще кэшируется, а that max.poll.records - всего лишь размер массива. max.poll.records The maximum number of records returned in a single call to poll(). Note, that max.poll.records does not impact the underlying fetching behavior. The consumer will cache the records from each fetch request and returns them incrementally from each poll. А для fetch другие настройки есть - максимальный размер в байтах и т.д. Но тогда непонятно, как по poll кафка определяет, что консьюмер упал. Правда, есть еще другая настройка heartbeat.interval.ms для пинга от консьюмера.

топ как всегда, крутая тема👍

Житель из деревни

Спасибо! Очень понятно и доходчиво, супер

Когда один пример стоит миллионов объяснений

👍

Добрый день. Спасибо за видео. Предлагаю идею следующей итерацией переделать на project loom

Продолжайте, толковый материал. Спасибо!

Спасибо!

Странно, вроде видео про применение gRPC, а кучу времени ушло на рассказ, как лучше работать со sleep или git... при том, что основную вещь "что такое setNumber(value)" не раскрыл

Лекция хорошая, но есть вопрос. Почему в build.gradle одни параметры выделены белым цветом, а другие серым и подчеркнуты?

Хоть с темой знаком, но всё равно смог узнать для себя что-то новое)

Сергей, здравствуйте. Подскажите пожалуйста, какие преимущества использовать outbox подход вместо встроенных транзакций кафки (KIP-98)

Спасибо, даже спустя два года все актуально)

Автору канала спасибо за труд, только один момент довольно сильно раздражает, перед каждым словом чавкать и произносить букву А, прочтите что-нибудь про ораторское искусство или о лексикографий, или что-то из преподавательской деятельности в целом, у вас не должно быть таких задержек и раздражающих привычек чтобы у слушателей не было таких ощущений, спасибо