В Кафке эпоха лидеров относится к числу лидеров, ранее назначенных контроллером. Каждый раз, когда происходит сбой лидера, контроллер выбирает нового лидера, увеличивает текущую «эпоху лидера» на 1 и разделяет эпоху лидера со всеми репликами. Реплики используют эпоху лидера в качестве средства проверки текущего лидера. Если лидер терпит неудачу и возвращается, когда он пытается связаться с другими репликами, он отправит то, что, по его мнению, является текущей эпохой лидера . Реплики будут игнорировать сообщения, отправленные с устаревшими лидерами .
Файл Leader-Epoch-Checkpoint содержит два столбца: эпохи и смещения, как показано здесь . Каждая строка является контрольной точкой для последней записанной эпохи лидера и последнего смещения лидера после становления лидером. И реплики, и лидеры содержат этот файл. Его роль заключается в проверке того, какой диапазон смещений относится к какой эпохе.