Запись в Kafka неблокирующая, но чтение из нее блокирует поток. Почему метод опроса Kafka не использует неблокирующий API и затем получает записи в обратном вызове?