Восстановление подсчёта голосов с Kafka предназначено для тех, кто знает базовые клиенты Kafka и хочет восстановить полезный бизнес-результат из сохранённых событий. Вы восстановите счётчики выставочных стендов, отличая повторно отправленное событие от нового голоса и сохраняя прогресс чтения существующего приложения отображения.
В двух пошаговых лабораторных работах вы сначала создадите глобальное правило идентичности, затем — полноценную программу независимого нативного повторного чтения. Одно самостоятельное задание применяет те же механизмы к двум новым выставочным пакетам и намеренному конфликту. Каждая часть начинается независимо. Автор оценивает весь курс примерно в 140–170 минут с чтением и обычными ошибками; это не измеренное время прохождения начинающими.
Чему вы научитесь
После завершения курса вы сможете:
- отличать партицию/смещение записи Kafka от глобального ID бизнес-события;
- считать идентичные повторные отправки один раз, сохраняя отдельными разные ID с одинаковым остальным содержимым;
- отклонять противоречивые значения одного ID вместо выбора победителя по порядку прибытия;
- получать зафиксированную границу каждой партиции и читать полный конечный пакет через пустые партиции, пропуски позиций и временно пустые опросы;
- публиковать и читать полные снимки с физическими исходными оболочками записей, логическими голосами и счётчиком каждого стенда, включая ноль;
- переиспользовать одну программу Python для разных каталогов и распределений партиций, не откатывая исходные группы отображения.
Для кого этот курс
Курс для изучающих Kafka, которые уже умеют публиковать и читать события JSON и хотят построить независимое производное представление.
Предварительные требования: Базовые пути терминала; функции, циклы, словари и JSON Python; ключи, партиции, смещения, группы консьюмеров и работа с производителями/консьюмерами Python для Kafka из Apache Kafka for Beginners. Пройдите обе пошаговые работы до самостоятельного задания.
Учебная среда: В каждой части доступны подготовленная среда Linux с Terminal, настоящий локальный брокер Kafka, установленный клиент Python, синтетические выставочные пакеты и средства чтения результата. Внешняя учётная запись или локальная установка не требуются. Команды, подписи инструментов и вывод выполнения используют английский язык.
Часто задаваемые вопросы
Это система идентификации голосующих или «один человек — один голос»?
Нет. Предоставленные бизнес-правила считают каждый новый ID события принятым голосом. Вы восстанавливаете эти события, но не устанавливаете личность реального посетителя и не решаете, разрешено ли ему голосовать снова.
Изучается ли непрерывный поток или обработка ровно один раз?
Курс работает с конечными зафиксированными журналами. Он учит полной реконструкции и отказу от конфликтов, не обещая восстановления непрерывных потоков, межсистемной атомарности, долговечности данных после аварии или сквозной обработки ровно один раз.
Как самостоятельное задание расширяет пошаговые работы?
Меняются имена стендов, отношения событий, количество и распределение партиций. Те же изученные интерфейсы Python и механизмы повторного чтения должны создать оба корректных снимка и отклонить намеренно конфликтный пакет, сохранив полезный результат.
