As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.
Caso queira criar uma configuração ativa-ativa em que os dois clusters do MSK estejam servindo ativamente leituras e gravações, recomendamos que você use um Replicador do MSK com replicação de nomes de tópicos prefixados (Adicionar prefixo ao nome de tópicos no console). No entanto, isso exigirá que você reconfigure os consumidores para ler os tópicos replicados.
Siga estas etapas para configurar a topologia ativa-ativa entre o cluster A de origem do MSK e o cluster B de destino do MSK.
Crie um replicador do MSK com o cluster A do MSK como origem e o cluster B do MSK como destino.
Depois que o replicador do MSK acima for criado com sucesso, crie um replicador com o cluster B como origem e o cluster A como destino.
Crie dois conjuntos de produtores, cada um gravando dados ao mesmo tempo no tópico local (p. ex., “topic”) no cluster na mesma região do produtor.
Crie dois conjuntos de consumidores, cada um lendo dados usando uma assinatura curinga (como”. *tópico”) do cluster MSK na mesma AWS região do consumidor. Dessa forma, seus consumidores lerão automaticamente os dados produzidos localmente na região com base no tópico local (p. ex.,
topic), bem como os dados replicados de outra região no tópico com o prefixo<sourceKafkaClusterAlias>.topic. Esses dois conjuntos de consumidores devem ter grupos de consumidores diferentes IDs para que as compensações do grupo de consumidores não sejam sobrescritas quando o MSK Replicator as copia para o outro cluster.
Se quiser evitar a reconfiguração dos clientes, em vez da replicação do nome de tópicos prefixados (Adicionar prefixo ao nome de tópicos no console), você pode criar os Replicadores do MSK usando a replicação de nomes de tópicos (mantenha o mesmo nome de tópicos no console) para criar uma configuração ativa-ativa. No entanto, você pagará taxas adicionais de processamento e transferência de dados para cada replicador. Isso ocorre porque cada replicador precisará processar o dobro da quantidade normal de dados: uma vez para a replicação e outra para evitar loops infinitos. Você pode rastrear a quantidade total de dados processados por cada replicador usando a métrica ReplicatorBytesInPerSec. Consulte Monitorar a replicação. Essa métrica inclui os dados replicados para o cluster de destino, bem como os dados filtrados pelo Replicador do MSK para evitar que os dados sejam copiados de volta para o mesmo tópico de origem.
nota
Se você estiver usando a replicação de nomes de tópicos idênticos (mantenha o mesmo nome de tópicos no console) para configurar a topologia ativa-ativa, aguarde pelo menos 30 segundos após excluir um tópico antes de recriar outro tópico com o mesmo nome. Esse período de espera ajuda a evitar que mensagens duplicadas sejam replicadas de volta para o cluster de origem. Seus consumidores devem ser capazes de reprocessar mensagens duplicadas sem impacto posterior. Consulte Considerações para criar aplicações do Apache Kafka em várias regiões.
