Вышеупомянутый метод Producer.send принимает в качестве параметра экземпляр типа Callback. После подтверждения получения записи ведущим брокером генератор инициирует выполнение метода Callback.onComplete. Только один из аргументов метода Callback.onComplete будет непустым. В данном случае нас интересует только вывод трассы вызовов при ошибке, так что нам важно, чтобы объект исключения был не пуст. Возвращаемый фьючерс после подтверждения получения записи сервером выдает объект типа RecordMetadata.

определение

В листинге 2.3 метод Producer.send возвращает объект Future, который представляет собой результат выполнения асинхронной операции. Что важнее, Future дает возможность извлечь результаты асинхронных операций отложенным образом, вместо того чтобы ждать их завершения. Более подробную информацию о фьючерсах вы можете найти в документации Java, в разделе «Интерфейс Future»: http:// mng.bz/0JK2.