Это сценарии сбоев, которые действительно требуют вашего вмешательства, и скучные исправления, которые их предотвращают.Потребитель Kafka — это клиент с состоянием, построенный на протоколе членства. Он присоединяется к группе, принимает назначение раздела, обрабатывает записи по порядку и доказывает, что он все еще жив, с помощью фиксированного ритма пульса и вызовов опроса. Каждая гарантия, которую предлагает группа — упорядоченная обработка, разделение нагрузки, ровно один владелец на раздел — опирается на стабильность этого членства во время потока работы через него.