Комментарии 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.
Может конечно я что-то не так поняла
Зарегистрируйтесь на Хабре, чтобы оставить комментарий
Оптимизация производительности цикла опроса в Kafka Consumer