запросы на сервер, если эти запросы ничего не возвращают? Я так понимаю ты хочешь минимизировать latency, то есть вычитывать и обрабатывать мессаджи с брокера максимально быстро от того момента как они там появились, добиться этого можно избавив поток работающий с консумером от необходимости выполнять обработку мессаджей, то есть разделить вычитывание мессаджей и их обработку по разным потокам, чтобы процессинг того что ты уже вычитал не оттягивал момент когда ты вызовешь poll. То есть нужно уходить от идиоматической однопоточного цикла в консумере и распаралеливаться. Если писать паралельную обработку самому то обязательно наделаешь кучу ошибок, лучше взять kafka-reactor для начала.
Всё проще, клиент спрашивает, что будет если мы не уследим за программистами и они из консьюмеров завалят запросами брокер. При этом у клиента есть уже негативный опыт реализации вещей по модели poll
Обсуждают сегодня