Reconstrução da contagem de votos com Kafka é um curso para quem conhece os clientes básicos do Kafka e quer reconstruir um resultado de negócio útil a partir de eventos retidos. Você reconstruirá contagens de estandes de exposição, distinguindo um evento reenviado de um novo voto e preservando o progresso de leitura de um aplicativo de exibição existente.
Dois laboratórios guiados desenvolvem a regra global de identidade e depois uma releitura nativa independente completa. Um desafio aplica os mesmos mecanismos a dois novos lotes de exposição e a um conflito deliberado. Cada unidade começa de forma independente. O autor estima cerca de 140–170 minutos para o curso, incluindo leitura e erros comuns; esse não é um tempo de conclusão medido com iniciantes.
O que você aprenderá
Ao concluir o curso, você poderá:
- distinguir a partição/offset de um registro Kafka de um ID global de evento de negócio;
- contar reenvios idênticos uma vez e manter separados IDs diferentes com o restante do conteúdo igual;
- recusar valores conflitantes do mesmo ID em vez de escolher um vencedor pela ordem de chegada;
- capturar o limite congelado de cada partição e ler um lote finito completo apesar de partições vazias, posições puladas e pollings temporariamente ociosos;
- publicar e ler snapshots completos com envelopes físicos da origem, votos lógicos e a contagem de todos os estandes, incluindo zero;
- reutilizar um programa Python em catálogos e distribuições de partições diferentes sem retroceder os grupos de exibição originais.
Para quem é este curso
Este curso é para estudantes de Kafka que já conseguem publicar e consumir eventos JSON e querem construir uma visão derivada independente.
Pré-requisitos: Caminhos básicos de terminal; funções, laços, dicionários e JSON em Python; chaves, partições, offsets, grupos de consumidores e trabalho com produtores/consumidores Python do Kafka apresentados em Apache Kafka for Beginners. Conclua os dois laboratórios guiados antes do desafio.
Ambiente de aprendizagem: Cada unidade fornece um ambiente Linux preparado com Terminal, um broker Kafka local real, o cliente Python instalado, lotes sintéticos de exposição e ferramentas de leitura dos resultados. Não é necessária conta externa nem instalação local. Comandos, rótulos de ferramentas e saída de execução usam inglês.
Perguntas frequentes
Este é um sistema de identidade de votantes ou de uma pessoa, um voto?
Não. As regras de negócio fornecidas tratam cada novo ID de evento como um voto aceito. Você reconstrói esses eventos; não estabelece quem é um visitante real nem se ele pode votar de novo.
O curso ensina streaming contínuo ou processamento exatamente uma vez?
O curso trabalha com logs finitos congelados. Ele ensina reconstrução completa e recusa de conflitos, sem prometer recuperação de fluxos contínuos, atomicidade entre sistemas, durabilidade após falhas abruptas nem comportamento exatamente uma vez de ponta a ponta.
Como o desafio amplia os laboratórios guiados?
Ele muda nomes de estandes, relações entre eventos e números e distribuições de partições. As mesmas interfaces Python e mecanismos de releitura ensinados devem produzir os dois snapshots válidos e recusar um lote deliberadamente conflitante preservando o resultado útil.
