Для обработки сегментов журналов Kafka использует настраиваемый пул потоков выполнения. В настоящий момент он применяется:
• при обычном запуске — для открытия сегментов журналов каждого из разделов;
• запуске после сбоя — для проверки и усечения сегментов журналов каждого из разделов;
• останове — для аккуратного закрытия сегментов журналов.
Apache Kafka. Потоковая обработка и анализ данных
·
Тодд ПалиноApache Kafka. Потоковая обработка и анализ данных
