Начиная с Apache Kafka 2.1, мы разделяем время, затраченное на отправку ProduceRecord, на два временных интервала, которые обрабатываются отдельно.
• Время до возвращения асинхронного вызова функции send(). В течение этого интервала поток, вызвавший функцию send(), будет заблокирован.
• Время с момента успешного возврата асинхронного вы
Apache Kafka. Потоковая обработка и анализ данных
·
Тодд Палино
