Он не блокируется при нормальных обстоятельствах, он возвращает ListenableFuture
, который можно использовать либо для блокировки (get()
), либо для получения ответа асинхронно с прослушиваемым.
Однако он блокирует ожидание метаданных темы при отправке первого сообщения, поэтому оно не реагирует.
Существует проект реактор-кафка , но Spring Kafka в настоящее время не использует его.
Существует запрос на получение , который мы планируем рассмотреть для следующей (2.3) версии.