Dentro da Trajetória de Ingestão em Tempo Real no Apache Pinot

Para garantir um único segmento "vencedor" consistente entre múltiplas réplicas de servidor Pinot que consomem a mesma partição Kafka, o Pinot emprega um protocolo de commit bloqueante leve ️, orquestrado por um controller. Neste processo, o controller elege um committer com base no max offset, enquanto os não-committers descartam suas versões locais e baixam a versão oficial.