Как стать автором
Обновить

Комментарии 2

Насколько нормально вызывать poll с нулевым таймаутом?

Делал так, запуская Kotlin корутину с Dispatchers.IO, и в цикле потом вызывая delay(), чтобы поток освобождался.

Сомневаюсь, что max.poll.records влияет на кол-во сетевых обращений. Из доки https://www.conduktor.io/kafka/kafka-consumer-important-settings-poll-and-internal-threads-behavior/

This setting does not impact the underlying fetching behavior. The consumer will cache the records from each fetch request and returns them incrementally from each poll.
Может конечно я что-то не так поняла

Зарегистрируйтесь на Хабре, чтобы оставить комментарий