Para simplificar o uso do SDK, o Data Transmission Service (DTS) implementa um mecanismo de tolerância a falhas. Esse mecanismo depende do relato em tempo real do horário de consumo ao nó de controle central do DTS enquanto o SDK processa os dados. Esta seção explica como usar o mecanismo de tolerância a falhas do SDK fornecido pelo DTS.
No código de consumo de mensagens do SDK, chame a API ackAsConsumed para cada mensagem consumida a fim de relatar o horário de consumo ao DTS.
Um canal de assinatura exige a execução de pelo menos um SDK primário e um secundário.
Arquitetura de consumo
Em um canal de assinatura do DTS, apenas um SDK pode extrair dados incrementais. Se houver vários SDKs downstream no mesmo canal, somente um deles receberá esses dados. Por isso, configure uma arquitetura de tolerância a falhas para o SDK.
Na arquitetura de exemplo da figura anterior, dois SDKs downstream conectam-se ao mesmo canal de assinatura e funcionam como primário e secundário entre si. Durante um mesmo período, apenas o SDK primário assina e consome os dados incrementais. Caso ocorram exceções no SDK primário ou na conexão de rede, o DTS inicia automaticamente o failover para o SDK secundário e o ativa com base no último horário de consumo registrado. Sempre que o SDK primário consome uma mensagem, ele envia uma mensagem ACK ao sistema de controle do DTS para informar o horário exato desse consumo.