Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
# Cos'è il replicatore Amazon MSK?
Amazon MSK Replicator è una funzionalità di Amazon MSK che consente di replicare in modo affidabile i dati tra cluster Amazon MSK diversi o uguali. Regione AWS Tuttavia, sia il cluster di origine che quello di destinazione devono trovarsi nello stesso ambiente. Account AWS Con il replicatore MSK, è possibile creare facilmente applicazioni di streaming resilienti a livello regionale per una maggiore disponibilità e continuità aziendale. Il replicatore MSK fornisce la replica asincrona automatica tra i cluster MSK, eliminando la necessità di scrivere codice personalizzato, gestire l'infrastruttura o configurare reti tra regioni.
Il replicatore MSK dimensiona automaticamente le risorse sottostanti in modo da poter replicare i dati on demand senza dover monitorare o dimensionare la capacità. MSK Replicator replica anche i metadati Kafka necessari, tra cui le configurazioni degli argomenti, le liste di controllo degli accessi () e gli offset dei gruppi di consumatori. ACLs Se si verifica un evento imprevisto in una regione, è possibile eseguire il failover nell'altra regione e riprendere l'elaborazione senza interruzioni. AWS
Il replicatore MSK supporta sia la replica tra regioni (CRR) sia la replica nella stessa regione (SRR). Nella replica tra regioni, i cluster MSK di origine e di destinazione si trovano in regioni diverse. AWS Nella replica nella stessa regione, i cluster MSK di origine e di destinazione si trovano nella stessa regione. AWS È necessario creare cluster MSK di origine e di destinazione prima di poterli utilizzare con il replicatore MSK.
**Nota**
MSK Replicator supporta le seguenti AWS regioni: Stati Uniti orientali (us-east-1, Virginia settentrionale); Stati Uniti orientali (us-east-2, Ohio); Stati Uniti occidentali (us-west-2, Oregon); Europa (eu-west-1, Irlanda); Europa (eu-central-1, Francoforte); Asia Pacifico (ap-southeast-1, Singapore); Asia Pacifico (ap-southeast-2, Sydney); Europa (eu-north-1, Stoccolma); Asia Pacifico (ap-south-1, Mumbai); Europa (eu-west-3, Parigi); Sud America (sa-east-1, San Paolo); Asia Pacifico (ap-northeast-2 Seoul); Europa (eu-west-2, Londra); Asia Pacifico (ap-northeast-1, Tokyo); Stati Uniti occidentali (us-west-1, California settentrionale); Canada (ca-central-1, centrale); Cina (Pechino) (cn-north-1); Cina (Ningxia) (cn-northwest-1); Asia Pacifico (Hyderabad) (ap-south-2), Asia Pacifico (Malesia) (ap-southeast-5), Asia Pacifico (Tailandia) (ap-southeast-7), Messico (Central) (mx-central-1), Asia Pacifico (Taipei) (ap-east-2), Canada occidentale (Calgary) (ca-west-1), Europa (Spagna) (eu-south-2), Medio Oriente (Bahrein) (me-south-1), Asia Pacifico (Giacarta) (ap-southeast-3) Africa (Città del Capo) (af-south-1), Medio Oriente (EAU) (me-central-1), Asia Pacifico (Hong Kong) (ap-east-1), Asia Pacifico (Osaka) (ap-northeast-3), Asia Pacifico (Osaka) (ap-northeast-3), Asia Pacifico (Melbourne) (ap-southeast-4), Europa (Milano) (eu-south-1), Israele (Tel Aviv) (il-central-1)), Europa (Zurigo) (eu-central-2) e Asia Pacifico (Nuova Zelanda) (ap-southeast-6)
Ecco alcuni usi comuni di Amazon MSK Replicator.
+ Crea applicazioni di streaming tra regioni: crea applicazioni di streaming ad alta disponibilità e tolleranti ai guasti per conseguire una maggiore resilienza senza necessità di configurare soluzioni personalizzate.
+ Fornisci un accesso ai dati a bassa latenza: offri un accesso ai dati con latenza inferiore ai consumatori ubicati in aree geografiche diverse.
+ Distribuisci i dati ai tuoi partner: copia i dati da un cluster Apache Kafka a più cluster Apache Kafka, in modo che diversi abbiano le proprie copie dei dati. teams/partners
+ Aggrega i dati per l'analisi: copia i dati da più cluster Apache Kafka in un unico cluster per generare facilmente approfondimenti su dati aggregati in tempo reale.
+ Scrivi localmente, accedi ai tuoi dati a livello globale: configura la replica multiattiva per propagare automaticamente le scritture eseguite in una AWS regione ad altre regioni per fornire dati a latenza e costi inferiori.
# Come funziona il replicatore Amazon MSK
Per iniziare a utilizzare MSK Replicator, è necessario creare un nuovo replicatore nella regione del cluster di destinazione. AWS *MSK Replicator copia automaticamente tutti i dati dal cluster nella AWS regione primaria denominata *origine* nel cluster nella regione di destinazione denominata destinazione.* I cluster di origine e di destinazione possono trovarsi nella stessa regione o in regioni diverse. AWS Se il cluster di destinazione non esiste ancora, devi crearlo.
Quando si crea un replicatore, MSK Replicator distribuisce tutte le risorse necessarie nella AWS regione del cluster di destinazione per ottimizzare la latenza di replica dei dati. La latenza di replica varia in base a molti fattori, tra cui la distanza di rete tra le AWS regioni dei cluster MSK, la capacità di throughput dei cluster di origine e di destinazione e il numero di partizioni sui cluster di origine e di destinazione. Il replicatore MSK dimensiona automaticamente le risorse sottostanti in modo da poter replicare i dati on demand senza dover monitorare o dimensionare la capacità.
## Replica dei dati
Per impostazione predefinita, MSK Replicator copia tutti i dati in modo asincrono dall'ultimo offset nelle partizioni tematiche del cluster di origine nel cluster di destinazione. Se l'impostazione «Rileva e copia nuovi argomenti» è attivata, MSK Replicator rileva e copia automaticamente nuovi argomenti o partizioni di argomenti nel cluster di destinazione. Tuttavia, il Replicator potrebbe impiegare fino a 30 secondi per rilevare e creare nuovi argomenti o partizioni di argomenti nel cluster di destinazione. Tutti i messaggi inviati all'argomento di origine prima della creazione dell'argomento nel cluster di destinazione non verranno replicati. In alternativa, è possibile [configurare il Replicator durante la creazione](msk-replicator-prepare-cluster.md) per avviare la replica dal primo offset nelle partizioni degli argomenti del cluster di origine se si desidera replicare i messaggi esistenti sui propri argomenti nel cluster di destinazione.
MSK Replicator non archivia i dati. I dati vengono utilizzati dal cluster di origine, inseriti nel buffer in memoria e scritti nel cluster di destinazione. Il buffer viene cancellato automaticamente quando i dati vengono scritti correttamente o hanno esito negativo dopo nuovi tentativi. Tutte le comunicazioni e i dati tra MSK Replicator e i cluster sono sempre crittografati durante il transito. Tutte le chiamate API MSK Replicator, ad esempio`DescribeClusterV2`, vengono acquisite in. `CreateTopic` `DescribeTopicDynamicConfiguration` AWS CloudTrail Anche i log del vostro broker MSK rifletteranno la stessa cosa.
MSK Replicator crea argomenti nel cluster di destinazione con un fattore di replica pari a 3. Se necessario, è possibile modificare il fattore di replica direttamente sul cluster di destinazione.
## Replica dei metadati
MSK Replicator supporta anche la copia dei metadati dal cluster di origine al cluster di destinazione. I metadati includono la configurazione degli argomenti, le liste di controllo degli accessi (ACLs) e gli offset dei gruppi di consumatori. Come la replica dei dati, anche la replica dei metadati avviene in modo asincrono. Per prestazioni migliori, MSK Replicator dà priorità alla replica dei dati rispetto alla replica dei metadati.
La tabella seguente è un elenco di elenchi di controllo degli accessi () copiati da MSK Replicator. ACLs
| Operation | Ricerca | APIs consentito |
| --- | --- | --- |
| Alter | Topic | CreatePartitions |
| AlterConfigs | Topic | AlterConfigs |
| Crea | Topic | CreateTopics, Metadati |
| Elimina | Topic | DeleteRecords, DeleteTopics |
| Describe | Topic | ListOffsets, Metadati, OffsetFetch OffsetForLeaderEpoch |
| DescribeConfigs | Topic | DescribeConfigs |
| Lettura | Topic | Recupera,, OffsetCommit TxnOffsetCommit |
| Scrivi (solo nega) | Topic | Produrre, AddPartitionsToTxn |
MSK Replicator copia il tipo di pattern LITERAL ACLs solo per il tipo di risorsa Topic. Il tipo di pattern ACLs PREFIXED e l'altro tipo di risorsa non vengono copiati. ACLs Inoltre, MSK Replicator non esegue l'eliminazione ACLs sul cluster di destinazione. Se si elimina un ACL sul cluster di origine, è necessario eliminarlo contemporaneamente anche sul cluster di destinazione. [Per maggiori dettagli sulle ACLs risorse, il pattern e le operazioni di Kafka, consulta https://kafka.apache.org/documentation/\$1security\$1authz\$1cli.](https://kafka.apache.org/documentation/#security_authz_cli)
MSK Replicator replica solo Kafka ACLs, che il controllo degli accessi IAM non utilizza. Se i clienti utilizzano il controllo degli accessi IAM ai cluster MSK, è necessario configurare le politiche IAM pertinenti anche sul cluster di destinazione per un failover senza interruzioni. read/write Questo vale anche per le configurazioni di replica dei nomi degli argomenti con prefisso e identico.
Nell'ambito della sincronizzazione degli offset dei gruppi di consumatori, MSK Replicator effettua l'ottimizzazione per i consumatori del cluster di origine che leggono da una posizione più vicina alla fine del flusso (partizione di fine argomento). Se i gruppi di consumatori sono in ritardo rispetto al cluster di origine, è possibile riscontrare un ritardo maggiore per tali gruppi di consumatori sul cluster di destinazione rispetto a quello di origine. Ciò significa che, dopo il failover sul cluster di destinazione, i consumatori rielaboreranno più messaggi duplicati. Per ridurre questo ritardo, i tuoi utenti del cluster di origine dovrebbero recuperare il ritardo e iniziare a consumare dall'estremità dello stream (fine della partizione dell'argomento). Man mano che i consumatori recuperano il ritardo, MSK Replicator ridurrà automaticamente il ritardo.
![\[Cluster di origine e di destinazione del replicatore MSK\]](http://docs.aws.amazon.com/it_it/msk/latest/developerguide/images/msk-replicator-diagram.png)
## Configurazione del nome dell'argomento
MSK Replicator dispone di due modalità di configurazione dei nomi degli argomenti: replica dei nomi degli argomenti con *prefisso* (impostazione predefinita) o *replica identica* dei nomi degli argomenti.
**Replica dei nomi degli argomenti con prefisso**
Per impostazione predefinita, MSK Replicator crea nuovi argomenti nel cluster di destinazione con un prefisso generato automaticamente aggiunto al nome dell'argomento del cluster di origine, ad esempio. `.topic` Questo serve a distinguere gli argomenti replicati dagli altri nel cluster di destinazione ed evitare la replica circolare dei dati tra i cluster.
Ad esempio, MSK Replicator replica i dati in un argomento denominato «topic» dal cluster di origine in un nuovo argomento nel cluster di destinazione denominato < alias>.topic. sourceKafkaCluster **È possibile trovare il prefisso che verrà aggiunto ai nomi degli argomenti nel cluster di destinazione nel campo **sourceKafkaClusterAlias utilizzando l'`DescribeReplicator`API o la pagina dei dettagli del Replicator** sulla console MSK.** Il prefisso nel cluster di destinazione è < Alias>. sourceKafkaCluster
Per garantire che i consumatori possano riavviare in modo affidabile l'elaborazione dal cluster di standby, è necessario configurare i consumatori in modo che leggano i dati degli argomenti utilizzando un operatore wildcard. `.*` Ad esempio, i tuoi consumatori dovrebbero utilizzare. `*topic1`in entrambe le AWS regioni. Questo esempio includerebbe anche un argomento come`footopic1`, quindi regola l'operatore wildcard in base alle tue esigenze.
È necessario utilizzare MSK Replicator che aggiunge un prefisso quando si desidera conservare i dati del replicatore in un argomento separato nel cluster di destinazione, ad esempio per le configurazioni di cluster attivo-attive.
**Argomento identico: replica dei nomi**
In alternativa all'impostazione predefinita, Amazon MSK Replicator consente di creare un replicatore con la replica degli argomenti impostata su Replica del nome dell'argomento identico (**mantieni lo stesso nome degli argomenti nella console**). È possibile creare un nuovo Replicator nella AWS regione in cui è presente il cluster MSK di destinazione. Gli argomenti replicati con nomi identici consentono di evitare di riconfigurare i client in modo che leggano argomenti replicati.
La replica identica dei nomi degli argomenti (**Mantieni lo stesso nome degli argomenti nella console) presenta i** seguenti vantaggi:
+ Consente di mantenere gli stessi nomi degli argomenti durante il processo di replica, evitando inoltre automaticamente il rischio di cicli di replica infiniti.
+ Semplifica la configurazione e il funzionamento di architetture di streaming multicluster, poiché consente di evitare di riconfigurare i client per la lettura degli argomenti replicati.
+ Per le architetture cluster attive e passive, la funzionalità di replica dei nomi degli argomenti identici semplifica inoltre il processo di failover, consentendo alle applicazioni di eseguire il failover senza problemi su un cluster di standby senza richiedere modifiche ai nomi degli argomenti o riconfigurazioni dei client.
+ Può essere utilizzata per consolidare più facilmente i dati di più cluster MSK in un unico cluster per l'aggregazione dei dati o l'analisi centralizzata. Ciò richiede la creazione di replicatori separati per ogni cluster di origine e lo stesso cluster di destinazione.
+ Può semplificare la migrazione dei dati da un cluster MSK a un altro replicando i dati su argomenti con nomi identici nel cluster di destinazione.
Amazon MSK Replicator utilizza le intestazioni Kafka per evitare automaticamente la replica dei dati sull'argomento da cui provengono, eliminando il rischio di cicli infiniti durante la replica. Un'intestazione è una coppia chiave-valore che può essere inclusa con la chiave, il valore e il timestamp in ogni messaggio Kafka. MSK Replicator incorpora gli identificatori per il cluster di origine e l'argomento nell'intestazione di ogni record replicato. MSK Replicator utilizza le informazioni di intestazione per evitare cicli di replica infiniti. È necessario verificare che i client siano in grado di leggere i dati replicati come previsto.
# Tutorial: configurare i cluster di origine e di destinazione per Amazon MSK Replicator
Questo tutorial mostra come configurare un cluster di origine e un cluster di destinazione nella stessa AWS regione o in AWS regioni diverse. Successivamente, puoi utilizzare questi cluster per creare un replicatore Amazon MSK.
# Preparare il cluster di origine Amazon MSK
Se disponi già di un cluster di origine MSK creato per il replicatore MSK, assicurati che soddisfi i requisiti descritti in questa sezione. Altrimenti, segui questi passaggi per creare un cluster di origine serverless o assegnato da MSK.
Il processo per la creazione di un cluster di origine del replicatore MSK tra regioni e nella stessa regione è simile. Le differenze vengono evidenziate nelle seguenti procedure.
1. Crea un cluster MSK Serverless o assegnato con il [Controllo degli accessi IAM attivato](create-iam-access-control-cluster-in-console.md) nella regione di origine. Il cluster di origine deve avere un minimo di tre broker.
1. Per un replicatore MSK tra regioni, se l'origine è un cluster assegnato, configuralo con la connettività privata multi-VPC attivata per gli schemi di Controllo degli accessi IAM. Tieni presente che il tipo di autenticazione non autenticato non è supportato quando è attivato il multi-VPC. Non è necessario attivare la connettività privata multi-VPC per altri schemi di autenticazione (MTL) o schemi di SASL/SCRAM). You can simultaneously use mTLS or SASL/SCRAM autenticazione per gli altri client che si connettono al cluster MSK. È possibile configurare la connettività privata multi-VPC tramite le **Impostazioni di rete** nei dettagli del cluster della console oppure tramite l'API `UpdateConnectivity`. Consulta la sezione [Il proprietario del cluster attiva il multi-VPC](mvpc-cluster-owner-action-turn-on.md). Se il cluster di origine è un cluster MSK Serverlesss, non è necessario attivare la connettività privata multi-VPC.
Per un replicatore MSK nella stessa regione, il cluster di origine MSK non richiede una connettività privata multi-VPC e altri client possono comunque accedere al cluster utilizzando il tipo di autenticazione non autenticato.
1. Per i replicatori MSK tra regioni, è necessario collegare una policy di autorizzazione basata sulle risorse al cluster di origine. Ciò consente a MSK di connettersi a questo cluster per replicare i dati. È possibile eseguire questa operazione utilizzando le procedure CLI o AWS Console riportate di seguito. Consulta anche la sezione [Policy basate sulle risorse di Amazon MSK](security_iam_service-with-iam.md). Non è necessario eseguire questa operazione per i replicatori MSK nella stessa regione.
------
#### [ Console: create resource policy ]
Aggiorna la policy del cluster di origine con il seguente codice JSON. Sostituisci il segnaposto con l'ARN del tuo cluster di origine.
****
```
{
"Version":"2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Principal": {
"Service": [
"kafka.amazonaws.com"
]
},
"Action": [
"kafka:CreateVpcConnection",
"kafka:GetBootstrapBrokers",
"kafka:DescribeClusterV2"
],
"Resource": "arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-5678-90ab-cdef-1234567890ab-1"
}
]
}
```
Utilizza l'opzione **Modifica policy del cluster** nel menu **Operazioni** nella pagina dei dettagli del cluster.
![\[Modifica della policy del cluster nella console\]](http://docs.aws.amazon.com/it_it/msk/latest/developerguide/images/edit-cluster-policy.png)
------
#### [ CLI: create resource policy ]
Nota: se utilizzi la AWS console per creare un cluster di origine e scegli l'opzione per creare un nuovo ruolo IAM, AWS allega la policy di fiducia richiesta al ruolo. Se invece desideri che MSK utilizzi un ruolo IAM esistente o se crei un ruolo autonomamente, collega la seguente policy di attendibilità a tale ruolo in modo che il replicatore MSK possa assumerlo. Per informazioni su come modificare la relazione di trust di un ruolo, consulta [Modifica di un ruolo](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_roles_manage_modify.html).
1. Recupera la versione corrente della policy del cluster MSK utilizzando questo comando. Sostituisci i segnaposto con l'ARN effettivo del cluster.
```
aws kafka get-cluster-policy —cluster-arn
{
"CurrentVersion": "K1PA6795UKM GR7",
"Policy": "..."
}
```
1. Crea una policy basata sulle risorse per consentire al replicatore MSK di accedere al cluster di origine. Utilizza la seguente sintassi come modello sostituendo il segnaposto con l'ARN effettivo del cluster di origine.
```
aws kafka put-cluster-policy --cluster-arn "" --policy '{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Principal": {
"Service": [
"kafka.amazonaws.com"
]
},
"Action": [
"kafka:CreateVpcConnection",
"kafka:GetBootstrapBrokers",
"kafka:DescribeClusterV2"
],
"Resource": ""
}
]
```
------
# Preparare il cluster di destinazione Amazon MSK
Crea un cluster di destinazione MSK (assegnato o serverless) con il Controllo degli accessi IAM attivato. Il cluster di destinazione non richiede l'attivazione della connettività privata multi-VPC. Il cluster di destinazione può trovarsi nella stessa AWS regione o in una regione diversa del cluster di origine. Sia il cluster di origine che quello di destinazione devono trovarsi nello stesso AWS account. Il cluster di destinazione deve avere un minimo di tre broker.
# Tutorial: creare un Amazon MSK Replicator
Dopo aver configurato i cluster di origine e di destinazione, puoi utilizzare tali cluster per creare un Amazon MSK Replicator. Prima di creare un replicatore Amazon MSK, assicurati di disporre delle [Autorizzazioni IAM necessarie per creare un replicatore MSK](msk-replicator-requirements.md#replicator-role-permissions-successful).
**Contents**
+ [Considerazioni sulla creazione di un Amazon MSK Replicator](msk-replicator-requirements.md)
+ [Autorizzazioni IAM necessarie per creare un replicatore MSK](msk-replicator-requirements.md#replicator-role-permissions-successful)
+ [Tipi e versioni di cluster supportati per MSK Replicator](msk-replicator-supported-clusters-versions.md)
+ [Configurazione del cluster MSK Serverless supportata](msk-replicator-serverless-requirements.md)
+ [Modifiche alla configurazione del cluster](msk-replicator-serverless-requirements.md#msk-replicator-config-changes)
+ [Crea un replicatore utilizzando la AWS console nella regione del cluster di destinazione](msk-replicator-create-console.md)
+ [Scelta del cluster di origine](msk-replicator-create-console.md#msk-replicator-create-console-choose-source)
+ [Scelta del cluster di destinazione](msk-replicator-create-console.md#msk-replicator-create-console-choose-target)
+ [Configurazione delle impostazioni e delle autorizzazioni del replicatore](msk-replicator-create-console.md#msk-replicator-create-settings)
# Considerazioni sulla creazione di un Amazon MSK Replicator
Le seguenti sezioni forniscono una panoramica dei prerequisiti, delle configurazioni supportate e delle best practice per l'utilizzo della funzionalità MSK Replicator. Descrive le autorizzazioni necessarie, la compatibilità dei cluster e i requisiti specifici di Serverless, oltre a indicazioni sulla gestione del Replicator dopo la creazione.
## Autorizzazioni IAM necessarie per creare un replicatore MSK
Ecco un esempio della policy IAM necessaria per creare un replicatore MSK. L'operazione `kafka:TagResource` è necessaria solo durante la creazione del replicatore MSK vengono forniti dei tag. Le policy IAM di Replicator devono essere associate al ruolo IAM corrispondente al cliente. Per informazioni sulla creazione di politiche di autorizzazione, consulta [Creare politiche di autorizzazione](https://docs.aws.amazon.com/msk/latest/developerguide/iam-access-control.html#create-iam-access-control-policies).
------
#### [ JSON ]
****
```
{
"Version":"2012-10-17",
"Statement": [
{
"Sid": "MSKReplicatorIAMPassRole",
"Effect": "Allow",
"Action": "iam:PassRole",
"Resource": "arn:aws:iam::123456789012:role/MSKReplicationRole",
"Condition": {
"StringEquals": {
"iam:PassedToService": "kafka.amazonaws.com"
}
}
},
{
"Sid": "MSKReplicatorServiceLinkedRole",
"Effect": "Allow",
"Action": "iam:CreateServiceLinkedRole",
"Resource": "arn:aws:iam::123456789012:role/aws-service-role/kafka.amazonaws.com/AWSServiceRoleForKafka*"
},
{
"Sid": "MSKReplicatorEC2Actions",
"Effect": "Allow",
"Action": [
"ec2:DescribeSubnets",
"ec2:DescribeSecurityGroups",
"ec2:DescribeVpcs",
"ec2:CreateNetworkInterface"
],
"Resource": [
"arn:aws:ec2:us-east-1:123456789012:subnet/subnet-0abcd1234ef56789",
"arn:aws:ec2:us-east-1:123456789012:security-group/sg-0123abcd4567ef89",
"arn:aws:ec2:us-east-1:123456789012:network-interface/eni-0a1b2c3d4e5f67890",
"arn:aws:ec2:us-east-1:123456789012:vpc/vpc-0a1b2c3d4e5f67890"
]
},
{
"Sid": "MSKReplicatorActions",
"Effect": "Allow",
"Action": [
"kafka:CreateReplicator",
"kafka:TagResource"
],
"Resource": [
"arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-56ef-78gh-90ij-klmnopqrstuv",
"arn:aws:kafka:us-east-1:123456789012:replicator/myReplicator/wxyz9876-54vu-32ts-10rq-ponmlkjihgfe"
]
}
]
}
```
------
Di seguito è riportata una policy IAM di esempio per descrivere il replicatore. È necessario specificare l'operazione `kafka:DescribeReplicator` o l'operazione `kafka:ListTagsForResource`, ma non entrambe.
------
#### [ JSON ]
****
```
{
"Version":"2012-10-17",
"Statement": [
{
"Sid": "VisualEditor1",
"Effect": "Allow",
"Action": [
"kafka:DescribeReplicator",
"kafka:ListTagsForResource"
],
"Resource": "*"
}
]
}
```
------
# Tipi e versioni di cluster supportati per MSK Replicator
Questi sono i requisiti per i tipi di istanze supportati, le versioni di Kafka e le configurazioni di rete.
+ Il replicatore MSK supporta sia i cluster assegnati da MSK sia i cluster MSK Serverless in qualsiasi combinazione di cluster di origine e di destinazione. Al momento, il replicatore MSK non supporta altri tipi di cluster Kafka.
+ I cluster MSK Serverless richiedono il Controllo degli accessi IAM, non supportano la replica delle ACL di Apache Kafka e offrono un supporto limitato per la replica della configurazione sull'argomento. Per informazioni, consulta [Cos'è MSK Serverless?](serverless.md).
+ MSK Replicator è supportato solo su cluster che eseguono Apache Kafka 2.7.0 o versioni successive, indipendentemente dal fatto che i cluster di origine e di destinazione si trovino nello stesso o in modo diverso. Regioni AWS
+ MSK Replicator supporta i cluster che utilizzano tipi di istanze m5.large o superiori. I cluster t3.small non sono supportati.
+ Se si utilizza il replicatore MSK con un cluster assegnato da MSK, sono necessari almeno tre broker sia nel cluster di origine sia in quello di destinazione. È possibile replicare i dati tra cluster in due zone di disponibilità, ma in tali cluster sono necessari almeno quattro broker.
+ I cluster MSK di origine e di destinazione devono appartenere allo stesso account. AWS La replica tra cluster in account diversi non è supportata.
+ Se i cluster MSK di origine e di destinazione si trovano in AWS regioni diverse (interregionali), MSK Replicator richiede che il cluster di origine abbia la connettività privata multi-VPC attivata per il metodo IAM Access Control.
Il multi-VPC non è richiesto per altri metodi di autenticazione sul cluster di origine per la replica MSK su tutto il cluster. Regioni AWS
Inoltre, il multi-VPC non è necessario se si replicano dati tra cluster nello stesso. Regione AWS Per informazioni, consulta [Connettività privata multi-VPC di Amazon MSK in un'unica regione](aws-access-mult-vpc.md).
+ La replica identica dei nomi degli argomenti (**Mantieni lo stesso nome degli argomenti** nella console) richiede un cluster MSK con Kafka versione 2.8.1 o successiva.
+ Per le configurazioni di replica identica dei nomi **degli argomenti (Mantieni lo stesso nome degli argomenti** nella console), per evitare il rischio di replica ciclica, non apportare modifiche alle intestazioni create da MSK Replicator (). `__mskmr`
# Configurazione del cluster MSK Serverless supportata
+ MSK Serverless supporta la replica di queste configurazioni di argomenti per i cluster di destinazione MSK Serverless durante la creazione degli argomenti: `cleanup.policy`, `compression.type`, `max.message.bytes`, `retention.bytes`, `retention.ms`.
+ MSK Serverless supporta solo queste configurazioni degli argomenti durante la sincronizzazione della configurazione degli argomenti: `compression.type`, `max.message.bytes`, `retention.bytes`, `retention.ms`.
+ Il replicatore utilizza 83 partizioni compattate sui cluster MSK Serverless di destinazione. Assicurati che i cluster MSK Serverless di destinazione abbiano un numero sufficiente di partizioni compattate. Per informazioni, consulta [Quota di MSK Serverless](limits.md#serverless-quota).
## Modifiche alla configurazione del cluster
+ Si consiglia di non attivare o disattivare l'archiviazione a più livelli dopo la creazione del replicatore MSK. Se il cluster di destinazione non è a più livelli, MSK non copierà le configurazioni di archiviazione a più livelli, indipendentemente dal fatto che il cluster di origine sia a più livelli o meno. Se si attiva l'archiviazione a più livelli sul cluster di destinazione dopo la creazione del replicatore, è necessario ricreare il replicatore. Se si desidera copiare i dati da un cluster non a più livelli a un cluster a più livelli, non è necessario copiare le configurazioni degli argomenti. Consulta la sezione [Abilitazione e disabilitazione dell'archiviazione a più livelli su un argomento esistente](https://docs.aws.amazon.com/msk/latest/developerguide/msk-enable-disable-topic-tiered-storage-cli.html).
+ Non modificare le impostazioni di configurazione del cluster dopo la creazione del replicatore MSK. Le impostazioni di configurazione del cluster vengono convalidate durante la creazione del replicatore MSK. Per evitare problemi con il replicatore MSK, non modificare le seguenti impostazioni dopo la creazione dello stesso.
+ Modifica il cluster MSK nel tipo di istanza t3.
+ Modifica i permessi del ruolo di esecuzione del servizio.
+ Disabilita la connettività privata multi-VPC di MSK.
+ Modifica la policy basata sulle risorse del cluster collegata.
+ Modifica le regole del gruppo di sicurezza del cluster.
# Crea un replicatore utilizzando la AWS console nella regione del cluster di destinazione
La sezione seguente spiega passo per passo il flusso di lavoro della console per la creazione di un replicatore.
**Dettagli del replicatore**
1. [Nella AWS regione in cui si trova il cluster MSK di destinazione, apri la console Amazon MSK da casahttps://console.aws.amazon.com/msk/? region=us-east-1\$1/home/.](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/)
1. Scegli **Replicatori** per visualizzare l'elenco dei replicatori presenti nell'account.
1. Scegli **Crea replicatore**.
1. Nel riquadro **Dettagli del replicatore**, assegna un nome univoco al nuovo replicatore.
## Scelta del cluster di origine
Il cluster di origine contiene i dati da copiare in un cluster MSK di destinazione.
1. Nel riquadro **Cluster di origine**, scegli la regione AWS in cui si trova il cluster di origine.
È possibile cercare la regione di un cluster accedendo a **Cluster MSK** e controllando i dettagli dell'ARN in **Cluster**. Il nome della regione è incorporato nella stringa ARN. Nell'ARN di esempio seguente, il cluster primario si trova nella regione `ap-southeast-2`.
```
arn:aws:kafka:ap-southeast-2:123456789012:cluster/cluster-11/eec93c7f-4e8b-4baf-89fb-95de01ee639c-s1
```
1. Inserisci l'ARN del tuo cluster di origine o naviga per scegliere il tuo cluster di origine.
1. Scegli una o più sottoreti per il cluster di origine.
La console mostra le sottoreti disponibili nella regione del cluster di origine che puoi selezionare. È necessario selezionare almeno due sottoreti. Per un replicatore MSK nella stessa regione, le sottoreti selezionate sono impostate per accedere al cluster di origine e le sottoreti per accedere al cluster di destinazione devono trovarsi nella stessa zona di disponibilità.
1. Scegliete uno o più gruppi di sicurezza per MSK Replicator per accedere al cluster di origine.
+ Per la replica tra regioni (CRR), non è necessario fornire gruppi di sicurezza per il cluster di origine.
+ Per la replica nella stessa regione (SRR), accedi alla console Amazon EC2 https://console.aws.amazon.com/ec2/ all'indirizzo e assicurati che i gruppi di sicurezza che fornirai per il Replicator dispongano di regole in uscita per consentire il traffico verso i gruppi di sicurezza del cluster di origine. Inoltre, assicurati che i gruppi di sicurezza del cluster di origine dispongano di regole in entrata che consentano il traffico proveniente dai gruppi di sicurezza Replicator forniti per l'origine.
**Per aggiungere regole in entrata al gruppo di sicurezza del cluster di origine:**
1. Nella AWS console, accedi ai dettagli del cluster di origine selezionando il **nome del cluster**.
1. Seleziona la scheda **Proprietà**, quindi scorri verso il basso fino al riquadro **Impostazioni di rete** e seleziona il nome del **Gruppo di sicurezza** applicato.
1. Vai alle regole in entrata e seleziona **Modifica le regole in entrata**.
1. Seleziona **Aggiungi regola**.
1. Nella colonna **Tipo** per la nuova regola, seleziona **TCP personalizzato**.
1. Nella colonna **Intervallo di porte**, digita`9098`. MSK Replicator utilizza il controllo degli accessi IAM per connettersi al cluster che utilizza la porta 9098.
1. **Nella colonna **Origine**, digita il nome del gruppo di sicurezza che fornirai durante la creazione di Replicator per il cluster di origine (potrebbe essere lo stesso del gruppo di sicurezza del cluster di origine MSK), quindi seleziona Salva regole.**
**Per aggiungere regole in uscita al gruppo di sicurezza di Replicator fornito per l'origine:**
1. Nella AWS console per Amazon EC2, vai al gruppo di sicurezza che fornirai durante la creazione di Replicator per l'origine.
1. Vai alle regole in uscita e seleziona **Modifica** regole in uscita.
1. Seleziona **Aggiungi regola**.
1. Nella colonna **Tipo** per la nuova regola, seleziona TCP **personalizzato**.
1. Nella colonna **Intervallo di porte**, digita`9098`. MSK Replicator utilizza il controllo degli accessi IAM per connettersi al cluster che utilizza la porta 9098.
1. **Nella colonna **Origine**, digita il nome del gruppo di sicurezza del cluster di origine MSK, quindi seleziona Salva regole.**
**Nota**
In alternativa, se non desideri limitare il traffico utilizzando i tuoi gruppi di sicurezza, puoi aggiungere regole in entrata e in uscita che consentono All Traffic.
1. Seleziona **Aggiungi regola**.
2. Nella colonna **Tipo**, seleziona **Tutto il traffico**.
3. Nella colonna Origine, digita `0.0.0.0/0` e quindi seleziona **Salva regole**.
## Scelta del cluster di destinazione
Il cluster di destinazione è il cluster MSK assegnato o serverless in cui vengono copiati i dati di origine.
**Nota**
Il replicatore MSK crea nuovi argomenti nel cluster di destinazione con un prefisso generato automaticamente aggiunto al nome dell'argomento. Ad esempio, il replicatore MSK replica i dati in "`topic`" dal cluster di origine a un nuovo argomento nel cluster di destinazione denominato `.topic`. Questo serve a distinguere gli argomenti che contengono i dati replicati dal cluster di origine da altri argomenti del cluster di destinazione ed evitare che i dati vengano replicati circolarmente tra i cluster. È possibile trovare il prefisso che verrà aggiunto ai nomi degli argomenti nel cluster di destinazione nel campo **sourceKafkaClusterAlias** utilizzando l'`DescribeReplicator`API o nella pagina dei **dettagli del Replicator sulla console MSK**. Il prefisso nel cluster di destinazione è. ``
1. Nel riquadro **Cluster di destinazione**, scegli la AWS regione in cui si trova il cluster di destinazione.
1. Inserisci l'ARN del cluster di destinazione o sfoglia l'elenco per scegliere il cluster di destinazione.
1. Scegli una o più sottoreti per il tuo cluster di destinazione.
La console mostra le sottoreti disponibili nella regione del cluster di destinazione che puoi selezionare. È necessario selezionare almeno due sottoreti.
1. Scegliete i gruppi di sicurezza per MSK Replicator per accedere al cluster di destinazione.
Vengono visualizzati i gruppi di sicurezza disponibili nella regione del cluster di destinazione che puoi selezionare. Il gruppo di sicurezza scelto è associato a ciascuna connessione. Per ulteriori informazioni sull'uso dei gruppi di sicurezza, consulta la sezione [Controlla il traffico verso AWS le tue risorse utilizzando i gruppi di sicurezza](https://docs.aws.amazon.com/vpc/latest/userguide/vpc-security-groups.html) nella *Amazon VPC User Guide*.
+ Sia per la replica tra regioni (CRR) che per la replica su stessa regione (SRR), accedi alla console Amazon EC2 all'indirizzo [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/)e assicurati che i gruppi di sicurezza che fornirai al Replicator dispongano di regole in uscita per consentire il traffico verso i gruppi di sicurezza del cluster di destinazione. Inoltre, assicurati che i gruppi di sicurezza del cluster di destinazione dispongano di regole in entrata che consentano il traffico verso i gruppi di sicurezza del replicatore forniti per la destinazione.
**Per aggiungere regole in entrata al gruppo di sicurezza del cluster di destinazione:**
1. Nella AWS console, accedi ai dettagli del cluster di destinazione selezionando il **nome del cluster**.
1. Seleziona la scheda **Proprietà**, quindi scorri verso il basso fino al riquadro Impostazioni di rete per selezionare il nome del **gruppo di sicurezza** applicato.
1. Vai alle regole in entrata e seleziona **Modifica le regole in entrata**.
1. Seleziona **Aggiungi regola**.
1. Nella colonna **Tipo** per la nuova regola, seleziona **TCP personalizzato**.
1. Nella colonna **Intervallo di porte**, digita`9098`. MSK Replicator utilizza il controllo degli accessi IAM per connettersi al cluster che utilizza la porta 9098.
1. **Nella colonna **Origine**, digita il nome del gruppo di sicurezza che fornirai durante la creazione di Replicator per il cluster di destinazione (potrebbe essere lo stesso del gruppo di sicurezza del cluster di destinazione MSK), quindi seleziona Salva regole.**
**Per aggiungere regole in uscita al gruppo di sicurezza di Replicator fornito per la destinazione:**
1. Nella AWS console, vai al gruppo di sicurezza che fornirai durante la creazione di Replicator per la destinazione.
1. Seleziona la scheda **Proprietà**, quindi scorri verso il basso fino al riquadro Impostazioni di rete per selezionare il nome del **gruppo di sicurezza** applicato.
1. Vai alle regole in uscita e seleziona **Modifica regole in uscita**.
1. Seleziona **Aggiungi regola**.
1. Nella colonna **Tipo** per la nuova regola, seleziona TCP **personalizzato**.
1. Nella colonna **Intervallo di porte**, digita`9098`. MSK Replicator utilizza il controllo degli accessi IAM per connettersi al cluster che utilizza la porta 9098.
1. **Nella colonna **Origine**, digita il nome del gruppo di sicurezza del cluster di destinazione MSK, quindi seleziona Salva regole.**
**Nota**
In alternativa, se non desideri limitare il traffico utilizzando i tuoi gruppi di sicurezza, puoi aggiungere regole in entrata e in uscita che consentono All Traffic.
1. Seleziona **Aggiungi regola**.
2. Nella colonna **Tipo**, seleziona **Tutto il traffico**.
3. Nella colonna Origine, digita `0.0.0.0/0` e quindi seleziona **Salva regole**.
## Configurazione delle impostazioni e delle autorizzazioni del replicatore
1. Nel riquadro **Impostazioni del replicatore**, specifica gli argomenti che desideri replicare utilizzando le espressioni regolari negli elenchi consentiti e non consentiti. Come impostazione predefinita, vengono replicati tutti gli argomenti.
**Nota**
MSK Replicator replica solo fino a 750 argomenti in ordine ordinato. Se è necessario replicare più argomenti, si consiglia di creare un Replicator separato. Vai al Support Center della AWS console e [crea un caso di supporto](https://console.aws.amazon.com/support/home#/) se hai bisogno di supporto per più di 750 argomenti per Replicator. È possibile monitorare il numero di argomenti replicati utilizzando la metrica TopicCount "». Per informazioni, consulta [Quota di broker Amazon MSK Standard](limits.md#msk-provisioned-quota).
1. Per impostazione predefinita, MSK Replicator avvia la replica dall'offset più *recente* (più recente) negli argomenti selezionati. In alternativa, è possibile avviare la replica dal *primo* offset (il più vecchio) negli argomenti selezionati se si desidera replicare i dati esistenti sugli argomenti. Una volta creato il Replicator, non è possibile modificare questa impostazione. Questa impostazione corrisponde al [https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators-replicatorarn.html#v1-replicators-replicatorarn-model-replicationstartingposition](https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators-replicatorarn.html#v1-replicators-replicatorarn-model-replicationstartingposition)campo della [https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators.html#CreateReplicator](https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators.html#CreateReplicator)richiesta e della [https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators-replicatorarn.html#DescribeReplicator](https://docs.aws.amazon.com/msk/1.0/apireference-replicator/v1-replicators-replicatorarn.html#DescribeReplicator)risposta APIs.
1. Scegli la configurazione del nome di un argomento:
+ `PREFIXED`replica del nome dell'argomento (**aggiungi il prefisso al nome dell'argomento** nella console): l'impostazione predefinita. MSK Replicator replica «topic1" dal cluster di origine in un nuovo argomento nel cluster di destinazione con lo stesso nome. `.topic1`
+ Replica identica dei nomi degli argomenti (**mantieni lo stesso nome degli argomenti** nella console): gli argomenti del cluster di origine vengono replicati con nomi di argomento identici nel cluster di destinazione.
Questa impostazione corrisponde al `TopicNameConfiguration` campo nella `CreateReplicator` richiesta e `DescribeReplicator` nella risposta. APIs Per informazioni, consulta [Come funziona il replicatore Amazon MSK](msk-replicator-how-it-works.md).
**Nota**
Per impostazione predefinita, MSK Replicator crea nuovi argomenti nel cluster di destinazione con un prefisso generato automaticamente aggiunto al nome dell'argomento. Questo serve a distinguere gli argomenti che contengono i dati replicati dal cluster di origine da altri argomenti del cluster di destinazione ed evitare che i dati vengano replicati circolarmente tra i cluster. In alternativa, è possibile creare un replicatore MSK con replica identica dei nomi degli argomenti (**mantenere lo stesso nome degli argomenti nella console) in modo che i nomi degli argomenti** vengano conservati durante la replica. Questa configurazione riduce la necessità di riconfigurare le applicazioni client durante la configurazione e semplifica il funzionamento di architetture di streaming multicluster.
1. Per impostazione predefinita, MSK Replicator copia tutti i metadati, incluse le configurazioni degli argomenti, le liste di controllo degli accessi () ACLs e gli offset dei gruppi di consumatori per un failover senza interruzioni. Se non si sta creando il replicatore per il failover, è possibile scegliere facoltativamente di disattivare una o più di queste impostazioni disponibili nella sezione **Impostazioni aggiuntive**.
**Nota**
MSK Replicator non replica la scrittura ACLs poiché i produttori non dovrebbero scrivere direttamente sull'argomento replicato nel cluster di destinazione. I produttori devono scrivere sull'argomento locale nel cluster di destinazione dopo il failover. Per informazioni dettagliate, vedi [Esegui un failover pianificato nella regione secondaria AWS](msk-replicator-perform-planned-failover.md).
1. Nel riquadro **Replica del gruppo di consumatori**, specifica i gruppi di consumatori che desideri replicare utilizzando le espressioni regolari negli elenchi consentiti e non consentiti. Per impostazione predefinita, vengono replicati tutti i gruppi di consumatori.
1. Nel riquadro **Compressione**, puoi facoltativamente scegliere di comprimere i dati scritti nel cluster di destinazione. Se intendi utilizzare la compressione, ti consigliamo di utilizzare lo stesso metodo di compressione dei dati nel cluster di origine.
1. Nel riquadro **Autorizzazioni di accesso**, effettua una delle operazioni seguenti:
1. Seleziona **Crea o aggiorna il ruolo IAM** con le policy richieste. La console MSK collegherà automaticamente le autorizzazioni e la policy di attendibilità necessarie al ruolo di esecuzione del servizio richiesto per la lettura e la scrittura nei cluster MSK di origine e di destinazione.
![\[Console MSK per creare o aggiornare il ruolo IAM del replicatore\]](http://docs.aws.amazon.com/it_it/msk/latest/developerguide/images/msk-replicator-ezCRC.png)
1. Fornisci il tuo ruolo IAM selezionando **Scegli tra i ruoli IAM che Amazon MSK può assumere**. Ti consigliamo di collegare la policy IAM `AWSMSKReplicatorExecutionRole` gestita al tuo ruolo di esecuzione del servizio, anziché scrivere la tua politica IAM.
1. Crea il ruolo IAM che il Replicator utilizzerà per leggere e scrivere nei cluster MSK di origine e di destinazione utilizzando il codice JSON riportato di seguito come parte della policy di fiducia e come `AWSMSKReplicatorExecutionRole` allegato al ruolo. Nella policy di attendibilità, sostituisci il segnaposto con l'ID dell'account effettivo.
------
#### [ JSON ]
****
```
{
"Version":"2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Principal": {
"Service": "kafka.amazonaws.com"
},
"Action": "sts:AssumeRole",
"Condition": {
"StringEquals": {
"aws:SourceAccount": ""
}
}
}
]
}
```
------
1. Nel riquadro **Tag del replicatore**, puoi facoltativamente assegnare tag alla risorsa replicatore MSK. Per ulteriori informazioni, consulta [Contrassegna un tag a un cluster Amazon MSK](msk-tagging.md). Per un replicatore MSK tra regioni, i tag vengono sincronizzati automaticamente con la regione remota al momento della creazione del replicatore. Se si modificano i tag dopo la creazione del replicatore, la modifica non viene sincronizzata automaticamente con la regione remota, quindi sarà necessario sincronizzare manualmente i riferimenti del replicatore locale e del replicatore remoto.
1. Seleziona **Crea**.
Se desideri limitare le `kafka-cluster:WriteData` autorizzazioni, consulta la sezione *Creare politiche di autorizzazione di* [Come funziona il controllo degli accessi IAM per Amazon MSK](https://docs.aws.amazon.com/msk/latest/developerguide/iam-access-control.html#how-to-use-iam-access-control). Dovrai aggiungere l'`kafka-cluster:WriteDataIdempotently`autorizzazione sia al cluster di origine che a quello di destinazione.
La creazione e la transizione del replicatore MSK allo stato RUNNING richiedono circa 30 minuti.
Se si crea un nuovo replicatore MSK per sostituirne uno eliminato, il nuovo replicatore avvia la replica dall'offset più recente.
Se il replicatore MSK è passato allo stato FAILED, consulta la sezione [Risoluzione dei problemi relativi al replicatore MSK](msk-replicator-troubleshooting.md).
# Modifica delle impostazioni del replicatore MSK
Non è possibile modificare il cluster di origine, il cluster di destinazione, la posizione iniziale del Replicator o la configurazione di replica dei nomi degli argomenti una volta creato MSK Replicator. È necessario creare un nuovo replicatore per utilizzare la configurazione di replica dei nomi degli argomenti identici. Tuttavia, è possibile modificare altre impostazioni del Replicator, ad esempio argomenti e gruppi di consumatori, da replicare.
1. Accedere a e aprire la console Amazon MSK da [https://console.aws.amazon.com/msk/casa? Console di gestione AWS region=us-east-1\$1/home/.](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/)
1. Nel riquadro di navigazione a sinistra, scegli **Replicatori per visualizzare l'elenco dei replicatori** presenti nell'account e seleziona il Replicatore MSK che desideri modificare.
1. Scegliere la scheda **Properties (Proprietà)**.
1. Nella sezione **Impostazioni del replicatore**, scegli **Modifica replicatore**.
1. È possibile modificare le impostazioni del replicatore MSK modificando una qualsiasi di queste impostazioni.
+ Specifica gli argomenti che desideri replicare utilizzando le espressioni regolari negli elenchi consentiti e non consentiti. Per impostazione predefinita, MSK Replicator copia tutti i metadati, tra cui le configurazioni degli argomenti, le liste di controllo degli accessi (ACLs) e gli offset dei gruppi di consumatori per un failover senza interruzioni. Se non si sta creando il replicatore per il failover, è possibile scegliere facoltativamente di disattivare una o più di queste impostazioni disponibili nella sezione **Impostazioni aggiuntive**.
**Nota**
MSK Replicator non replica la scrittura ACLs poiché i produttori non dovrebbero scrivere direttamente sull'argomento replicato nel cluster di destinazione. I produttori devono scrivere sull'argomento locale nel cluster di destinazione dopo il failover. Per informazioni dettagliate, vedi [Esegui un failover pianificato nella regione secondaria AWS](msk-replicator-perform-planned-failover.md).
+ In **Replica del gruppo di consumatori**, puoi specificare i gruppi di consumatori che desideri replicare utilizzando le espressioni regolari negli elenchi consentiti e non consentiti. Per impostazione predefinita, vengono replicati tutti i gruppi di consumatori. Se gli elenchi consentiti e non consentiti sono vuoti, la replica dei gruppi di consumatori è disattivata.
+ In **Tipo di compressione di destinazione**, puoi scegliere se comprimere i dati scritti nel cluster di destinazione. Se intendi utilizzare la compressione, ti consigliamo di utilizzare lo stesso metodo di compressione dei dati nel cluster di origine.
1. Salvare le modifiche.
La creazione e la transizione del replicatore MSK allo stato di esecuzione richiedono circa 30 minuti. Se il replicatore MSK è passato allo stato FAILED, consulta la sezione [Risolvete i problemi relativi a MSK Replicator](msk-replicator-troubleshooting.md) sulla risoluzione dei problemi.
# Eliminazione di un replicatore MSK
Se la creazione di un replicatore MSK ha esito negativo (stato FAILED), potrebbe essere necessario eliminarlo. I cluster di origine e di destinazione assegnati a un replicatore MSK non possono essere modificati una volta creato il replicatore MSK. È possibile eliminare un replicatore MSK esistente e crearne uno nuovo. Se si crea un nuovo replicatore MSK per sostituire quello eliminato, il nuovo replicatore avvia la replica dall'offset più recente.
1. Nella AWS regione in cui si trova il cluster di origine, accedi e apri la console Amazon MSK da [https://console.aws.amazon.com/msk/casa? Console di gestione AWS region=us-east-1\$1/home/.](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/)
1. Nel riquadro di navigazione, seleziona **Replicatori**.
1. Dall'elenco dei replicatori MSK, seleziona quello che desideri eliminare e scegli **Elimina**.
# Monitoraggio della replica
È possibile utilizzarlo [https://console.aws.amazon.com/cloudwatch/](https://console.aws.amazon.com/cloudwatch/)nella regione del cluster di destinazione per `ReplicationLatency` visualizzare i parametri e `ReplicatorThroughput` a livello di argomento e aggregazione per ogni Amazon MSK Replicator. `MessageLag` Le metriche sono visibili **ReplicatorName**nello spazio dei nomi «/Kafka».AWS Per verificare la presenza di problemi, puoi anche consultare i parametri `ReplicatorFailure`, `AuthError` e `ThrottleTime`.
La console MSK visualizza un sottoinsieme di metriche per ogni MSK Replicator. CloudWatch Dall'elenco dei **Replicatori** della console, seleziona il nome di un replicatore e scegli la scheda **Monitoraggio**.
## Parametri del replicatore MSK
I parametri seguenti descrivono i parametri delle prestazioni o delle connessioni per il replicatore MSK.
AuthError le metriche non coprono gli errori di autenticazione a livello di argomento. Per monitorare gli errori di autenticazione a livello di argomento di MSK Replicator, monitorate le metriche di Replicator e le metriche a livello di argomento del ReplicationLatency cluster di origine,. MessagesInPerSec Se un argomento è ReplicationLatency stato ridotto a 0 ma l'argomento contiene ancora dati in corso, significa che il Replicator ha un problema di autenticazione con l'argomento. Verifica che il ruolo IAM per l'esecuzione del servizio del replicatore disponga di autorizzazioni sufficienti per accedere all'argomento.
****
[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/it_it/msk/latest/developerguide/msk-replicator-monitor.html)
# Utilizza la replica per aumentare la resilienza di un'applicazione di streaming Kafka in tutte le regioni
È possibile utilizzare MSK Replicator per configurare topologie di cluster attive-attive o attive-passive per aumentare la resilienza dell'applicazione Apache Kafka in tutte le regioni. AWS In una configurazione attiva-attiva, entrambi i cluster MSK eseguono attivamente operazioni di lettura e scrittura. In una configurazione attiva-passiva, solo un cluster MSK alla volta serve attivamente lo streaming di dati, mentre l'altro cluster è in standby.
## Considerazioni per la creazione di applicazioni Apache Kafka multiregione
I consumatori devono essere in grado di rielaborare i messaggi duplicati senza ripercussioni a valle. MSK Replicator replica i dati at-least-once che possono causare duplicati nel cluster di standby. Quando si passa alla AWS regione secondaria, i consumatori possono elaborare gli stessi dati più di una volta. Il replicatore MSK dà la priorità alla copia dei dati rispetto agli offset dei consumatori per prestazioni migliori. Dopo un failover, il consumatore può iniziare a leggere dagli offset precedenti con conseguente duplicazione dell'elaborazione.
I produttori e i consumatori devono inoltre tollerare una perdita minima di dati. Poiché MSK Replicator replica i dati in modo asincrono, quando la AWS regione primaria inizia a riscontrare errori, non vi è alcuna garanzia che tutti i dati vengano replicati nella regione secondaria. È possibile utilizzare la latenza di replica per determinare il numero massimo di dati che non sono stati copiati nella regione secondaria.
## Utilizzo della topologia di cluster attiva-attiva rispetto a quella attiva-passiva
Una topologia di cluster attiva-attiva offre tempi di ripristino quasi nulli e la possibilità per l'applicazione di streaming di funzionare contemporaneamente in più regioni AWS . Quando un cluster in una regione è danneggiato, le applicazioni connesse al cluster nell'altra regione continuano a elaborare i dati.
Le configurazioni attive-passive sono adatte alle applicazioni che possono essere eseguite in una sola regione AWS alla volta o quando è necessario un maggiore controllo sull'ordine di elaborazione dei dati. Le configurazioni attive-passive richiedono più tempo di ripristino rispetto alle configurazioni attive-attive, poiché, dopo un failover, è necessario avviare l'intera configurazione attiva-passiva, compresi produttori e consumatori, nella regione secondaria per riprendere lo streaming dei dati.
# Crea una configurazione di cluster Kafka attivo-passiva con le configurazioni di denominazione degli argomenti consigliate
Per una configurazione attiva-passiva, ti consigliamo di utilizzare una configurazione simile di produttori, cluster MSK e consumatori (con lo stesso nome di gruppo di consumatori) in due regioni diverse. AWS È importante che i due cluster MSK abbiano capacità di lettura e scrittura identiche per garantire una replica affidabile dei dati. È necessario creare un replicatore MSK per copiare continuamente i dati dal cluster primario a quello di standby. È inoltre necessario configurare i produttori in modo che scrivano i dati in argomenti su un cluster nella stessa regione. AWS
Per una configurazione attiva-passiva, create un nuovo replicatore con replica identica dei nomi degli argomenti (**mantieni lo stesso nome degli argomenti** nella console) per iniziare a replicare i dati dal tuo cluster MSK nella regione primaria al cluster nella regione secondaria. Si consiglia di utilizzare un set duplicato di produttori e consumatori nelle due AWS regioni, ciascuno dei quali si connette al cluster della propria regione utilizzando la propria stringa di bootstrap. Ciò semplifica il processo di failover poiché non richiede modifiche alla stringa di bootstrap. Per garantire che i consumatori leggano da dove l'avevano interrotto, i consumatori dei cluster di origine e di destinazione devono avere lo stesso ID del gruppo di consumatori.
Se si utilizza la replica identica dei nomi degli argomenti (**Mantieni lo stesso nome degli argomenti** nella console) per MSK Replicator, gli argomenti verranno replicati con lo stesso nome degli argomenti di origine corrispondenti.
Si consiglia di configurare le impostazioni e le autorizzazioni a livello di cluster per i client nel cluster di destinazione. Non è necessario configurare le impostazioni a livello di argomento e la lettura letterale, ACLs poiché MSK Replicator le copia automaticamente se è stata selezionata l'opzione per copiare le liste di controllo degli accessi. Per informazioni, consulta [Replica dei metadati](msk-replicator-how-it-works.md#msk-replicator-metadata-replication).
# Failover nella regione secondaria AWS
Ti consigliamo di monitorare la latenza di replica nella AWS regione secondaria utilizzando Amazon. CloudWatch Durante un evento di servizio nella AWS regione principale, la latenza di replica può aumentare improvvisamente. Se la latenza continua ad aumentare, utilizza il AWS Service Health Dashboard per verificare la presenza di eventi di servizio nella AWS regione principale. Se si verifica un evento, puoi eseguire il failover nella regione secondaria AWS .
# Esegui un failover pianificato nella regione secondaria AWS
È possibile eseguire un failover pianificato per testare la resilienza dell'applicazione rispetto a un evento imprevisto nella AWS regione principale in cui si trova il cluster MSK di origine. Un failover pianificato non dovrebbe comportare la perdita di dati.
Se utilizzi un argomento identico alla configurazione della replica dei nomi, segui questi passaggi:
1. Arresta tutti i produttori e i consumatori che si connettono al cluster di origine.
1. Crea un nuovo replicatore MSK per replicare i dati dal cluster MSK nella regione secondaria al cluster MSK nella regione principale con la replica identica dei nomi degli argomenti (**mantieni lo stesso nome degli** argomenti nella console). Ciò è necessario per copiare i dati che verranno scritti dalla regione secondaria alla regione primaria, in modo da poter eseguire il failback nella regione primaria al termine dell'evento imprevisto.
1. Avvia produttori e consumatori collegati al cluster di destinazione nella regione secondaria. AWS
Se utilizzi la configurazione dei nomi degli argomenti con prefisso, segui questi passaggi per il failover:
1. Arresta tutti i produttori e i consumatori che si connettono al cluster di origine.
1. Crea un nuovo replicatore MSK per replicare i dati dal cluster MSK nella regione secondaria al cluster MSK nella regione primaria. Ciò è necessario per copiare i dati che verranno scritti dalla regione secondaria alla regione primaria, in modo da poter eseguire il failback nella regione primaria al termine dell'evento imprevisto.
1. Avvia i produttori sul cluster target nella regione secondaria AWS .
1. A seconda dei requisiti di ordinamento dei messaggi dell'applicazione, segui i passaggi indicati in una delle schede seguenti.
------
#### [ No message ordering ]
Se l'applicazione non richiede l'ordinamento dei messaggi, avvia i consumatori della AWS regione secondaria che leggono sia gli argomenti locali (ad esempio, topic) che quelli replicati (ad esempio`.topic`) utilizzando un operatore wildcard (ad esempio,). `.*topic`
------
#### [ Message ordering ]
Se l'applicazione richiede l'ordinamento dei messaggi, avvia i consumatori solo per gli argomenti replicati sul cluster di destinazione (ad esempio, `.topic`) ma non per gli argomenti locali (ad esempio, `topic`).
------
1. Attendi che tutti i consumatori degli argomenti replicati sul cluster MSK di destinazione completino l'elaborazione di tutti i dati, in modo che il ritardo del consumatore sia 0 e anche il numero di record elaborati sia 0. Quindi, interrompi i consumatori per gli argomenti replicati sul cluster di destinazione. A questo punto, tutti i record replicati dal cluster MSK di origine al cluster MSK di destinazione sono stati utilizzati.
1. Avvia i consumatori per gli argomenti locali (ad esempio, `topic`) sul cluster MSK di destinazione.
# Eseguite un failover non pianificato nella regione secondaria AWS
È possibile eseguire un failover non pianificato quando si verifica un evento di servizio nella AWS regione principale in cui è presente il cluster MSK di origine e si desidera reindirizzare temporaneamente il traffico verso la regione secondaria che include il cluster MSK di destinazione. Un failover non pianificato potrebbe causare una perdita di dati poiché MSK Replicator replica i dati in modo asincrono. È possibile tenere traccia del ritardo dei messaggi utilizzando le metriche in. [Monitoraggio della replica](msk-replicator-monitor.md)
Se utilizzi la configurazione di replica dei nomi degli argomenti identica (**mantieni lo stesso nome degli argomenti** nella console), segui questi passaggi:
1. Prova a chiudere tutti i produttori e i consumatori che si connettono al cluster MSK di origine nella regione primaria. Questa operazione potrebbe non riuscire a causa di problemi in quella regione.
1. Avvia i produttori e i consumatori a connettersi al cluster MSK di destinazione nella AWS regione secondaria per completare il failover. Poiché MSK Replicator replica anche i metadati, compresi gli offset di lettura ACLs e gli offset dei gruppi di consumatori, i produttori e i consumatori riprenderanno senza problemi l'elaborazione quasi da dove l'avevano interrotta prima del failover.
Se utilizzi la configurazione del nome dell'`PREFIX`argomento, segui questi passaggi per il failover:
1. Prova a chiudere tutti i produttori e i consumatori che si connettono al cluster MSK di origine nella regione primaria. Questa operazione potrebbe non riuscire a causa di problemi in quella regione.
1. Avvia i produttori e i consumatori a connettersi al cluster MSK di destinazione nella AWS regione secondaria per completare il failover. Poiché MSK Replicator replica anche i metadati, compresi gli offset di lettura ACLs e gli offset dei gruppi di consumatori, i produttori e i consumatori riprenderanno senza problemi l'elaborazione quasi da dove l'avevano interrotta prima del failover.
1. A seconda dei requisiti di ordinamento dei messaggi dell'applicazione, segui i passaggi indicati in una delle schede seguenti.
------
#### [ No message ordering ]
Se l'applicazione non richiede l'ordinamento dei messaggi, avviate i consumatori della AWS regione di destinazione che leggono sia gli argomenti locali (ad esempio) che quelli replicati (ad esempio`topic`) utilizzando un operatore wildcard (ad esempio,`.topic`). `.*topic`
------
#### [ Message ordering ]
1. Avvia i consumatori solo per gli argomenti replicati nel cluster di destinazione (ad esempio, `.topic`) ma non per gli argomenti locali (ad esempio, `topic`).
1. Attendi che tutti i consumatori degli argomenti replicati sul cluster MSK di destinazione completino l'elaborazione di tutti i dati, in modo che il ritardo di offset sia 0 e anche il numero di record elaborati sia 0. Quindi, interrompi i consumatori per gli argomenti replicati sul cluster di destinazione. A questo punto, tutti i record replicati dal cluster MSK di origine al cluster MSK di destinazione sono stati utilizzati.
1. Avvia i consumatori per gli argomenti locali (ad esempio, `topic`) sul cluster MSK di destinazione.
------
1. Una volta terminato l'evento di servizio nella regione primaria, create un nuovo replicatore MSK per replicare i dati dal cluster MSK nella regione secondaria al cluster MSK nella regione primaria con la posizione iniziale del replicatore impostata sulla *prima*. Ciò è necessario per copiare i dati che verranno scritti dalla regione secondaria alla regione primaria, in modo da poter eseguire il failback nella regione primaria al termine dell'evento di servizio. Se non impostate la posizione iniziale del Replicator sulla *prima*, i dati prodotti nel cluster nella regione secondaria durante l'evento di servizio nell'area primaria non verranno copiati nuovamente nel cluster nell'area primaria.
# Eseguire il failback nella regione principale AWS
È possibile eseguire il failback AWS nella regione principale al termine dell'evento di servizio in quella regione.
Se utilizzi la configurazione della replica dei nomi per argomento identico, segui questi passaggi:
1. Crea un nuovo Replicatore MSK con il cluster secondario come origine e il cluster primario come destinazione, impostando la posizione iniziale sulla replica del nome dell'argomento *più antica* e identica (**mantieni lo stesso nome degli argomenti** nella console).
In questo modo verrà avviato il processo di copia di tutti i dati scritti nel cluster secondario dopo il failover nella regione primaria.
1. Monitora la `MessageLag` metrica sul nuovo replicatore in Amazon CloudWatch fino al raggiungimento`0`, il che indica che tutti i dati sono stati replicati dal secondario al primario.
1. Dopo che tutti i dati sono stati replicati, interrompi la connessione di tutti i produttori al cluster secondario e avvia i produttori a connettersi al cluster primario.
1. Attendi `MaxOffsetLag` che i tuoi consumatori si connettano al cluster secondario `0` per assicurarti di aver elaborato tutti i dati. Per informazioni, consulta [Monitora i ritardi dei consumatori](consumer-lag.md).
1. Una volta che tutti i dati sono stati elaborati, interrompi i consumatori nell'area secondaria e avvia i consumatori a connettersi al cluster primario per completare il failback.
1. Eliminate il replicatore creato nel primo passaggio, che consiste nella replica dei dati dal cluster secondario a quello primario.
1. Verifica che il Replicator esistente che copia i dati dal cluster primario a quello secondario abbia lo stato «RUNNING» e il `ReplicatorThroughput` parametro in Amazon. CloudWatch `0`
*Tieni presente che quando crei un nuovo Replicator con la posizione iniziale Earliest for failback, inizia a leggere tutti i dati negli argomenti relativi ai cluster secondari.* A seconda delle impostazioni di conservazione dei dati, gli argomenti possono contenere dati provenienti dal cluster di origine. Sebbene MSK Replicator filtri automaticamente tali messaggi, dovrete comunque sostenere costi di elaborazione e trasferimento dei dati per tutti i dati del cluster secondario. È possibile tenere traccia del totale dei dati elaborati dal replicatore utilizzando. `ReplicatorBytesInPerSec` Per informazioni, consulta [Parametri del replicatore MSK](msk-replicator-monitor.md#msk-replicator-metrics).
Se utilizzi la configurazione dei nomi degli argomenti con prefisso, segui questi passaggi:
È necessario avviare le fasi di failback solo dopo che la replica dal cluster nella regione secondaria al cluster nella regione primaria è stata ripristinata e il MessageLag parametro in CloudWatch Amazon è vicino a 0. Un failback pianificato non dovrebbe comportare la perdita di dati.
1. Arresta tutti i produttori e i consumatori che si connettono al cluster MSK nella regione secondaria.
1. Per la topologia attiva-passiva, elimina il replicatore che replica i dati dal cluster nella regione secondaria alla regione primaria. Non è necessario eliminare il replicatore per la topologia attiva-attiva.
1. Avvia i produttori che si connettono al cluster MSK nella regione primaria.
1. A seconda dei requisiti di ordinamento dei messaggi dell'applicazione, segui i passaggi indicati in una delle schede seguenti.
------
#### [ No message ordering ]
Se la tua applicazione non richiede l'ordinamento dei messaggi, avvia i consumatori della AWS regione primaria che leggono sia gli argomenti locali (ad esempio`topic`) che quelli replicati (ad esempio) utilizzando un operatore wildcard (ad esempio,`.topic`). `.*topic` I consumatori sugli argomenti locali (ad esempio: topic) riprenderanno dall'ultimo offset utilizzato prima del failover. Se erano presenti dati non elaborati prima del failover, verranno elaborati ora. Nel caso di un failover pianificato, tale record non dovrebbe esistere.
------
#### [ Message ordering ]
1. Avvia i consumatori solo per gli argomenti replicati nella regione primaria (ad esempio, `.topic`) ma non per gli argomenti locali (ad esempio, `topic`).
1. Attendi che tutti i consumatori degli argomenti replicati sul cluster nella regione primaria completino l'elaborazione di tutti i dati, in modo che il ritardo di offset sia 0 e anche il numero di record elaborati sia 0. Quindi, interrompi i consumatori per gli argomenti replicati sul cluster nella regione primaria. A questo punto, tutti i record prodotti nella regione secondaria dopo il failover sono stati utilizzati nella regione primaria.
1. Avvia i consumatori per gli argomenti locali (ad esempio, `topic`) sul cluster nella regione primaria.
------
1. Verificate che il replicatore esistente dal cluster nella regione primaria al cluster nella regione secondaria sia nello stato RUNNING e funzioni come previsto utilizzando le `ReplicatorThroughput` metriche di latenza e.
# Creare una configurazione attiva-attiva utilizzando MSK Replicator
**Se si desidera creare una configurazione attiva-attiva in cui entrambi i cluster MSK eseguano attivamente operazioni di lettura e scrittura, si consiglia di utilizzare un replicatore MSK con replica dei nomi degli argomenti con prefisso (aggiungi il prefisso al nome degli argomenti nella console).** Tuttavia, ciò richiederà la riconfigurazione dei consumatori per la lettura degli argomenti replicati.
Segui questi passaggi per configurare la topologia attiva-attiva tra il cluster MSK di origine A e il cluster MSK di destinazione B.
1. Crea un replicatore MSK con il cluster MSK A come origine e il cluster MSK B come destinazione.
1. Dopo aver creato correttamente il replicatore MSK precedente, crea un replicatore con il cluster B come origine e il cluster A come destinazione.
1. Crea due set di produttori, ognuno dei quali scrive i dati contemporaneamente nell'argomento locale (ad esempio, "topic") nel cluster nella stessa regione del produttore.
1. Crea due set di consumatori, ciascuno dei quali legge i dati utilizzando un abbonamento wildcard (ad esempio». \$1topic») dal cluster MSK nella stessa AWS regione del consumatore. In questo modo, i consumatori leggeranno automaticamente i dati prodotti localmente nella regione dall'argomento locale (ad esempio, `topic`), nonché i dati replicati dall'altra regione nell'argomento con il prefisso `.topic`. Questi due gruppi di consumatori devono avere gruppi di consumatori diversi in IDs modo che gli offset dei gruppi di consumatori non vengano sovrascritti quando MSK Replicator li copia nell'altro cluster.
Se si desidera evitare la riconfigurazione dei client, anziché utilizzare la replica dei nomi degli argomenti con prefisso (**aggiungere il prefisso al nome degli argomenti nella console), è possibile creare i replicatori MSK utilizzando la replica dei nomi** degli argomenti identici (**Mantieni** lo stesso nome degli argomenti nella console) per creare una configurazione attiva-attiva. Tuttavia, pagherete costi aggiuntivi per l'elaborazione e il trasferimento dei dati per ogni Replicator. Questo perché ogni replicatore dovrà elaborare il doppio della normale quantità di dati, una volta per la replica e un'altra per evitare cicli infiniti. È possibile tenere traccia della quantità totale di dati elaborati da ciascun replicatore utilizzando la metrica. `ReplicatorBytesInPerSec` Per informazioni, consulta [Monitoraggio della replica](msk-replicator-monitor.md). Questa metrica include i dati replicati nel cluster di destinazione e i dati filtrati da MSK Replicator per evitare che i dati vengano ricondotti allo stesso argomento da cui provengono.
**Nota**
Se utilizzi la replica identica dei nomi degli argomenti (**Mantieni lo stesso nome degli argomenti** nella console) per configurare una topologia attiva-attiva, attendi almeno 30 secondi dopo aver eliminato un argomento prima di ricrearne uno con lo stesso nome. Questo periodo di attesa consente di evitare che i messaggi duplicati vengano replicati nel cluster di origine. I consumatori devono essere in grado di rielaborare i messaggi duplicati senza ripercussioni a valle. Per informazioni, consulta [Considerazioni per la creazione di applicazioni Apache Kafka multiregione](msk-replicator-increase-resiliency.md#msk-replication-multi-region-kafka-applications).
# Esegui la migrazione da un cluster Amazon MSK a un altro utilizzando MSK Replicator
Puoi utilizzare la replica dei nomi degli argomenti identici per la migrazione dei cluster, ma i tuoi consumatori devono essere in grado di gestire messaggi duplicati senza alcun impatto a valle. Questo perché MSK Replicator fornisce la replica, che può portare a messaggi at-least-once duplicati in rari scenari. Se i tuoi consumatori soddisfano questo requisito, segui questi passaggi.
1. *Crea un replicatore che replica i dati dal tuo vecchio cluster al nuovo cluster con la posizione iniziale di Replicator impostata su Earliest e utilizzando la replica identica dei nomi degli argomenti (**mantieni lo stesso nome degli argomenti** nella console).*
1. Configura le impostazioni e le autorizzazioni a livello di cluster sul nuovo cluster. Non è necessario configurare le impostazioni a livello di argomento e la lettura «letterale» ACLs, poiché MSK Replicator le copia automaticamente.
1. Monitora la `MessageLag` metrica in Amazon CloudWatch fino a raggiungere lo 0, il che indica che tutti i dati sono stati replicati.
1. Dopo che tutti i dati sono stati replicati, impedisci ai produttori di scrivere dati sul vecchio cluster.
1. Riconfigura quei produttori per connetterli al nuovo cluster e avviali.
1. Monitora i `MaxOffsetLag` parametri relativi ai consumatori che leggono i dati dal vecchio cluster fino a quando non diventano effettivi`0`, il che indica che tutti i dati esistenti sono stati elaborati.
1. Impedisci ai consumatori che si connettono al vecchio cluster.
1. Riconfigura i consumatori per connettersi al nuovo cluster e avviarli.
# Esegui la migrazione da MirrorMaker 2 a gestione automatica a MSK Replicator
Per migrare da MirrorMaker (MM2) a MSK Replicator, attenersi alla seguente procedura:
1. Interrompi il produttore che sta scrivendo sul tuo cluster Amazon MSK di origine.
1. Consenti MM2 di replicare tutti i messaggi sugli argomenti dei cluster di origine. È possibile monitorare il ritardo dei MM2 consumatori per ciascun utente sul cluster MSK di origine per determinare quando tutti i dati sono stati replicati.
1. Create un nuovo Replicator con la posizione iniziale impostata su Più *recente* e la configurazione del nome dell'argomento impostata su `IDENTICAL` (**Replica dei nomi degli stessi argomenti** nella console).
1. Una volta che il Replicator è nello stato RUNNING, è possibile riavviare i produttori a scrivere nel cluster di origine.
# Risolvete i problemi relativi a MSK Replicator
Le seguenti informazioni agevolano la risoluzione dei problemi che si potrebbero verificare con il replicatore MSK. [Risolvi i problemi del tuo cluster Amazon MSK](troubleshooting.md)Per informazioni sulla risoluzione dei problemi relative ad altre funzionalità di Amazon MSK, consulta. Puoi anche pubblicare il problema in [AWS re:Post](https://repost.aws/).
## Lo stato del replicatore MSK passa da CREATING a FAILED
Di seguito sono riportate alcune cause comuni degli errori di creazione del replicatore MSK.
1. Assicurati che i gruppi di sicurezza che hai fornito per la creazione del replicatore nella sezione del cluster di destinazione dispongano di regole in uscita per consentire il traffico verso i gruppi di sicurezza del cluster di destinazione. Inoltre, assicurati che i gruppi di sicurezza del cluster di destinazione dispongano di regole in entrata che consentano il traffico verso i gruppi di sicurezza che fornisci per la creazione del replicatore nella sezione del cluster di destinazione. Per informazioni, consulta [Scelta del cluster di destinazione](msk-replicator-create-console.md#msk-replicator-create-console-choose-target).
1. Se stai creando il replicatore per la replica tra regioni, verifica che per il cluster di origine sia attivata la connettività multi-VPC per il metodo di autenticazione Controllo degli accessi IAM. Per informazioni, consulta [Connettività privata multi-VPC di Amazon MSK in un'unica regione](aws-access-mult-vpc.md). Verifica inoltre che la policy del cluster sia configurata sul cluster di origine in modo che il replicatore MSK possa connettersi a esso. Per informazioni, consulta [Preparare il cluster di origine Amazon MSK](msk-replicator-prepare-cluster.md).
1. Assicurati che il ruolo IAM fornito durante la creazione del replicatore MSK disponga delle autorizzazioni necessarie per leggere e scrivere nei cluster di origine e di destinazione. Inoltre, verifica che il ruolo IAM disponga delle autorizzazioni per scrivere sugli argomenti. Per informazioni, consultare [Configurazione delle impostazioni e delle autorizzazioni del replicatore](msk-replicator-create-console.md#msk-replicator-create-settings).
1. Verifica che la tua rete non ACLs stia bloccando la connessione tra MSK Replicator e i cluster di origine e di destinazione.
1. È possibile che i cluster di origine o di destinazione non fossero completamente disponibili quando il replicatore MSK ha tentato di connettersi a essi. Ciò potrebbe essere dovuto a un carico eccessivo, all'utilizzo del disco o della CPU, che impedisce al replicatore di connettersi ai broker. Risolvi il problema con i broker e prova di nuovo a creare il replicatore.
Dopo aver eseguito le convalide precedenti, crea nuovamente il replicatore MSK.
## Il replicatore MSK appare bloccato nello stato CREATING
A volte la creazione del replicatore MSK può richiedere fino a 30 minuti. Attendi 30 minuti e controlla nuovamente lo stato del replicatore.
## Il replicatore MSK non replica dati o replica soltanto dati parziali
Seguire questi passaggi per risolvere i problemi di replica dei dati.
1. Verifica che il tuo Replicator non stia riscontrando errori di autenticazione utilizzando la AuthError metrica fornita da MSK Replicator in Amazon. CloudWatch Se questo parametro è superiore a 0, verifica se la policy del ruolo IAM fornito per il replicatore è valida e che non siano impostate autorizzazioni di rifiuto per le autorizzazioni del cluster. In base alla dimensione clusterAlias, è possibile verificare se è il cluster di origine o quello di destinazione a presentare errori di autenticazione.
1. Verifica che i cluster di origine e di destinazione non presentino problemi. È possibile che il replicatore non sia in grado di connettersi al cluster di origine o di destinazione. Ciò può accadere a causa di un numero eccessivo di connessioni, di un disco a piena capacità o di un elevato utilizzo della CPU.
1. Verifica che i cluster di origine e di destinazione siano raggiungibili da MSK Replicator utilizzando la metrica KafkaClusterPingSuccessCount in Amazon. CloudWatch In base alla dimensione clusterAlias, è possibile verificare se è il cluster di origine o di destinazione a presentare errori di autenticazione. Se questo parametro è 0 o non ha un punto di dati, la connessione non è integra. È necessario verificare le autorizzazioni di rete e i ruoli IAM utilizzati dal replicatore MSK per connettersi ai cluster.
1. Verifica che il tuo Replicator non stia riscontrando errori dovuti alla mancanza di autorizzazioni a livello di argomento utilizzando la metrica in Amazon. ReplicatorFailure CloudWatch Se questo parametro è superiore a 0, controlla il ruolo IAM che hai fornito per le autorizzazioni a livello di argomento.
1. Verifica che l'espressione regolare che hai fornito nell'elenco consentito durante la creazione del replicatore corrisponda ai nomi degli argomenti che desideri replicare. Inoltre, verifica che gli argomenti non vengano esclusi dalla replica a causa di un'espressione regolare nell'elenco degli argomenti non consentiti.
1. Tieni presente che il Replicator potrebbe impiegare fino a 30 secondi per rilevare e creare nuovi argomenti o partizioni di argomenti sul cluster di destinazione. Tutti i messaggi inviati all'argomento di origine prima della creazione dell'argomento nel cluster di destinazione non verranno replicati se la posizione iniziale del replicatore è la più recente (impostazione predefinita). In alternativa, è possibile avviare la replica dal primo offset nelle partizioni degli argomenti del cluster di origine se si desidera replicare i messaggi esistenti sui propri argomenti nel cluster di destinazione. Per informazioni, consulta [Configurazione delle impostazioni e delle autorizzazioni del replicatore](msk-replicator-create-console.md#msk-replicator-create-settings).
## Gli offset dei messaggi nel cluster di destinazione sono diversi da quelli del cluster di origine
Nell'ambito della replica dei dati, MSK Replicator consuma i messaggi dal cluster di origine e li produce nel cluster di destinazione. Ciò può portare a messaggi con offset diversi sui cluster di origine e di destinazione. Tuttavia, se è stata attivata la sincronizzazione degli offset dei gruppi di consumatori durante la creazione di Replicator, MSK Replicator tradurrà automaticamente gli offset durante la copia dei metadati in modo che, dopo il failover sul cluster di destinazione, gli utenti possano riprendere l'elaborazione da dove l'avevano interrotta nel cluster di origine.
## MSK Replicator non sincronizza gli offset dei gruppi di consumatori oppure il gruppo di consumatori non esiste nel cluster di destinazione
Segui questi passaggi per risolvere i problemi di replica dei metadati.
1. Verifica che la replica dei dati funzioni come previsto. In caso contrario, vedi[Il replicatore MSK non replica dati o replica soltanto dati parziali](#msk-replicator-troubleshooting-not-replicating).
1. Verifica che l'espressione regolare che hai fornito nell'elenco consentito durante la creazione del Replicator corrisponda ai nomi dei gruppi di consumatori che desideri replicare. Inoltre, verificate che i gruppi di consumatori non vengano esclusi dalla replica a causa di un'espressione regolare nell'elenco degli utenti non autorizzati.
1. Verificate che MSK Replicator abbia creato l'argomento sul cluster di destinazione. Potrebbero essere necessari fino a 30 secondi prima che il Replicator rilevi e crei i nuovi argomenti o le partizioni degli argomenti sul cluster di destinazione. Tutti i messaggi inviati all'argomento di origine prima della creazione dell'argomento nel cluster di destinazione non verranno replicati se la posizione iniziale del replicatore è la *più recente* (impostazione predefinita). Se il gruppo di consumatori nel cluster di origine ha utilizzato solo i messaggi che non sono stati replicati da MSK Replicator, il gruppo di consumatori non verrà replicato nel cluster di destinazione. Dopo aver creato correttamente l'argomento sul cluster di destinazione, MSK Replicator inizierà a replicare i nuovi messaggi scritti dal cluster di origine alla destinazione. Una volta che il gruppo di consumatori inizia a leggere questi messaggi dall'origine, MSK Replicator replicherà automaticamente il gruppo di consumatori nel cluster di destinazione. In alternativa, è possibile avviare la replica dal primo offset nelle partizioni degli argomenti del cluster di origine se si desidera replicare i messaggi esistenti sui propri argomenti nel cluster di destinazione. Per informazioni, consulta [Configurazione delle impostazioni e delle autorizzazioni del replicatore](msk-replicator-create-console.md#msk-replicator-create-settings).
**Nota**
MSK Replicator ottimizza la sincronizzazione dell'offset dei gruppi di consumatori per i consumatori del cluster di origine che leggono da una posizione più vicina alla fine della partizione degli argomenti. Se i gruppi di consumatori sono in ritardo rispetto al cluster di origine, è possibile riscontrare un ritardo maggiore per tali gruppi di consumatori sul cluster di destinazione rispetto a quello di origine. Ciò significa che, dopo il failover sul cluster di destinazione, i consumatori rielaboreranno più messaggi duplicati. Per ridurre questo ritardo, i tuoi utenti del cluster di origine dovrebbero recuperare il ritardo e iniziare a consumare dall'estremità dello stream (fine della partizione dell'argomento). Man mano che i consumatori recuperano il ritardo, MSK Replicator ridurrà automaticamente il ritardo.
## La latenza di replica è elevata o continua ad aumentare
Di seguito sono riportate alcune cause comuni dell'elevata latenza di replica.
1. Verifica di disporre del numero corretto di partizioni nei cluster MSK di origine e di destinazione. Un numero di partizioni troppo basso o elevato può influire sulle prestazioni. Per indicazioni sulla scelta del numero di partizioni, consulta la sezione [Best practice per l'utilizzo del replicatore MSK](msk-replicator-best-practices.md). La tabella seguente mostra il numero minimo di partizioni consigliato per ottenere la velocità di trasmissione effettiva desiderata con il replicatore MSK.
**Velocità di trasmissione effettiva e numero minimo consigliato di partizioni**
[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/it_it/msk/latest/developerguide/msk-replicator-troubleshooting.html)
1. Verifica di disporre di una capacità di lettura e scrittura sufficiente nei cluster MSK di origine e di destinazione per supportare il traffico di replica. Il replicatore MSK funge da consumatore per il cluster di origine (uscita) e da produttore per il cluster di destinazione (ingresso). Pertanto, è necessario fornire la capacità del cluster per supportare il traffico di replica oltre al resto del traffico sui cluster. Consulta la sezione [Best practice per l'utilizzo del replicatore MSK](msk-replicator-best-practices.md) per indicazioni sul dimensionamento dei cluster MSK.
1. La latenza di replica può variare per i cluster MSK in diverse coppie di AWS regioni di origine e destinazione, a seconda della distanza geografica dei cluster l'uno dall'altro. Ad esempio, la latenza di replica è in genere inferiore quando si esegue la replica tra cluster nelle regioni Europa (Irlanda) ed Europa (Londra) rispetto alla replica tra cluster nelle regioni Europa (Irlanda) e Asia Pacifico (Sydney).
1. Assicurati che il replicatore non subisca limitazioni a causa delle quote eccessivamente aggressive impostate sui cluster di origine o di destinazione. Puoi utilizzare la ThrottleTime metrica fornita da MSK Replicator in Amazon CloudWatch per vedere il tempo medio, in millisecondi, in cui una richiesta è stata limitata dai broker del tuo cluster. source/target Se questo parametro è superiore a 0, è necessario modificare le quote Kafka per ridurre la limitazione della larghezza di banda della rete in modo che il replicatore possa recuperare il ritardo. Per informazioni sulla gestione delle quote Kafka per il replicatore, consulta la pagina [Gestione della velocità di trasmissione effettiva del replicatore MSK utilizzando le quote Kafka](msk-replicator-best-practices.md#msk-replicator-manage-throughput-kafka-quotas).
1. ReplicationLatency e potrebbe aumentare quando una regione si deteriora. MessageLag AWS Utilizza [Dashboard AWS Service Health](https://health.aws.amazon.com/health/status) per verificare la presenza di un evento del servizio MSK nella regione in cui si trova il cluster MSK primario. Se si verifica un evento di servizio, è possibile reindirizzare temporaneamente le operazioni di lettura e scrittura dell'applicazione all'altra regione.
## Risoluzione dei problemi relativi agli errori di MSK Replicator utilizzando la metrica ReplicatorFailure
La ReplicatorFailure metrica consente di monitorare e rilevare i problemi di replica in MSK Replicator. Un valore diverso da zero di questa metrica indica in genere un problema di errore di replica, che potrebbe derivare dai seguenti fattori:
+ limitazioni alla dimensione dei messaggi
+ violazioni dell'intervallo di data e ora
+ registra i problemi relativi alla dimensione del batch
Se la ReplicatorFailure metrica riporta un valore diverso da zero, segui questi passaggi per risolvere il problema.
**Nota**
Per ulteriori informazioni su questa metrica, consulta [Parametri del replicatore MSK](msk-replicator-monitor.md#msk-replicator-metrics).
1. Configura un client in grado di connettersi al cluster MSK di destinazione e che disponga degli strumenti CLI di Apache Kafka. Per informazioni sulla configurazione del client e dello strumento Kafka CLI, vedere. [Connect a un cluster Amazon MSK Provisioned](client-access.md)
1. Aprire la console Amazon MSK a [https://console.aws.amazon.com/msk/casa? region=us-east-1\$1/home/.](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/)
Successivamente, esegui queste operazioni:
1. Ottenete il file di MSK Replicator e il cluster MSK di destinazione. ARNs
1. [Ottieni gli endpoint del broker del cluster MSK](get-bootstrap-console.md) di destinazione. Utilizzerai questi endpoint nei passaggi seguenti.
1. Eseguite i seguenti comandi per esportare l'ARN di MSK Replicator e gli endpoint del broker ottenuti nel passaggio precedente.
Assicuratevi di sostituire i valori segnaposto per < *ReplicatorARN* >, < > e < *BootstrapServerString* *ConsumerConfigFile* > utilizzati negli esempi seguenti con i valori effettivi.
```
export TARGET_CLUSTER_SERVER_STRING=
```
```
export REPLICATOR_ARN=
```
```
export CONSUMER_CONFIG_FILE=
```
1. Nella tua `/bin` directory, procedi come segue:
1. Salva il seguente script e assegnagli un nome**query-replicator-failure-message.sh**.
```
#!/bin/bash
# Script: Query MSK Replicator Failure Message
# Description: This script queries exceptions from AWS MSK Replicator status topics
# It takes a replicator ARN and bootstrap server as input and searches for replicator exceptions
# in the replicator's status topic, formatting and displaying them in a readable manner
#
# Required Arguments:
# --replicator-arn: The ARN of the AWS MSK Replicator
# --bootstrap-server: The Kafka bootstrap server to connect to
# --consumer.config: Consumer config properties file
# Usage Example:
# ./query-replicator-failure-message.sh ./query-replicator-failure-message.sh --replicator-arn --bootstrap-server --consumer.config
print_usage() {
echo "USAGE: $0 ./query-replicator-failure-message.sh --replicator-arn --bootstrap-server --consumer.config "
echo "--replicator-arn REQUIRED: The ARN of AWS MSK Replicator."
echo "--bootstrap-server REQUIRED: The Kafka server to connect to."
echo "--consumer.config REQUIRED: Consumer config properties file."
exit 1
}
# Initialize variables
replicator_arn=""
bootstrap_server=""
consumer_config=""
# Parse arguments
while [[ $# -gt 0 ]]; do
case "$1" in
--replicator-arn)
if [ -z "$2" ]; then
echo "Error: --replicator-arn requires an argument."
print_usage
fi
replicator_arn="$2"; shift 2 ;;
--bootstrap-server)
if [ -z "$2" ]; then
echo "Error: --bootstrap-server requires an argument."
print_usage
fi
bootstrap_server="$2"; shift 2 ;;
--consumer.config)
if [ -z "$2" ]; then
echo "Error: --consumer.config requires an argument."
print_usage
fi
consumer_config="$2"; shift 2 ;;
*) echo "Unknown option: $1"; print_usage ;;
esac
done
# Check for required arguments
if [ -z "$replicator_arn" ] || [ -z "$bootstrap_server" ] || [ -z "$consumer_config" ]; then
echo "Error: --replicator-arn, --bootstrap-server, and --consumer.config are required."
print_usage
fi
# Extract replicator name and suffix from ARN
replicator_arn_suffix=$(echo "$replicator_arn" | awk -F'/' '{print $NF}')
replicator_name=$(echo "$replicator_arn" | awk -F'/' '{print $(NF-1)}')
echo "Replicator name: $replicator_name"
# List topics and find the status topic
topics=$(./kafka-topics.sh --command-config client.properties --list --bootstrap-server "$bootstrap_server")
status_topic_name="__amazon_msk_replicator_status_${replicator_name}_${replicator_arn_suffix}"
# Check if the status topic exists
if echo "$topics" | grep -Fq "$status_topic_name"; then
echo "Found replicator status topic: '$status_topic_name'"
./kafka-console-consumer.sh --bootstrap-server "$bootstrap_server" --consumer.config "$consumer_config" --topic "$status_topic_name" --from-beginning | stdbuf -oL grep "Exception" | stdbuf -oL sed -n 's/.*Exception:\(.*\) Topic: \([^,]*\), Partition: \([^\]*\).*/ReplicatorException:\1 Topic: \2, Partition: \3/p'
else
echo "No topic matching the pattern '$status_topic_name' found."
fi
```
1. Esegui questo script per interrogare i messaggi di errore di MSK Replicator.
```
/bin/query-replicator-failure-message.sh --replicator-arn $REPLICATOR_ARN --bootstrap-server $TARGET_CLUSTER_SERVER_STRING --consumer.config $CONSUMER_CONFIG_FILE
```
Questo script restituisce tutti gli errori con i relativi messaggi di eccezione e le partizioni tematiche interessate. È possibile utilizzare queste informazioni sulle eccezioni per mitigare gli errori come descritto in. [Errori comuni di MSK Replicator e relative soluzioni](#msk-replicator-ReplicatorFailure-error-mitigation) Poiché l'argomento contiene tutti i messaggi di errore cronologici, avviate l'indagine utilizzando l'ultimo messaggio. Di seguito è riportato un esempio di messaggio di errore.
```
ReplicatorException: The request included a message larger than the max message size the server will accept. Topic: test, Partition: 1
```
### Errori comuni di MSK Replicator e relative soluzioni
L'elenco seguente descrive alcuni degli errori di MSK Replicator che potrebbero verificarsi e come mitigarli.
**Dimensione del messaggio superiore a max.request.size**
**Causa**
Questo errore si verifica quando MSK Replicator non riesce a replicare i dati perché la dimensione del singolo messaggio supera i 10 MB. Per impostazione predefinita, MSK Replicator replica messaggi di dimensioni fino a 10 MB.
Di seguito è riportato un esempio di questo tipo di messaggio di errore.
```
ReplicatorException: The message is 20635370 bytes when serialized which is larger than 10485760, which is the value of the max.request.size configuration. Topic: test, Partition: 1
```
**Soluzione**
Riduci le dimensioni dei singoli messaggi nel tuo argomento. Se non riesci a farlo, segui queste istruzioni per [richiedere un aumento del limite](limits.md#request-msk-quota-increase).
**Dimensione del messaggio superiore alla dimensione massima del messaggio che il server accetterà**
**Causa**
Questo errore si verifica quando la dimensione del messaggio supera la dimensione massima del messaggio del cluster di destinazione.
Di seguito è riportato un esempio di questo tipo di messaggio di errore.
```
ReplicatorException: The request included a message larger than the max message size the server will accept. Topic: test, Partition: 1
```
**Soluzione**
Aumenta la `max.message.bytes` configurazione sul cluster di destinazione o sull'argomento del cluster di destinazione corrispondente. Imposta la `max.message.bytes` configurazione del cluster di destinazione in modo che corrisponda alla dimensione massima dei messaggi non compressi. [Per informazioni su questa operazione, consulta max.message.bytes.](https://kafka.apache.org/documentation/#topicconfigs_max.message.bytes)
**Il timestamp non è compreso nell'intervallo**
**Causa**
Questo errore si verifica perché il timestamp del singolo messaggio non rientra nell'intervallo consentito del cluster di destinazione.
Di seguito è riportato un esempio di questo tipo di messaggio di errore.
```
ReplicatorException: Timestamp 1730137653724 of message with offset 0 is out of range. The timestamp should be within [1730137892239, 1731347492239] Topic: test, Partition: 1
```
**Soluzione**
Aggiorna la `message.timestamp.before.max.ms` configurazione del cluster di destinazione per consentire la ricezione di messaggi con timestamp precedenti. [Per informazioni su questa operazione, consulta message.timestamp.before.max.ms.](https://kafka.apache.org/documentation/#topicconfigs_message.timestamp.before.max.ms)
**Il batch di registrazione è troppo grande**
**Causa**
Questo errore si verifica perché la dimensione del batch di record supera la dimensione del segmento impostata per l'argomento nel cluster di destinazione. MSK Replicator supporta una dimensione massima del batch di 1 MB.
Di seguito è riportato un esempio di questo tipo di messaggio di errore.
```
ReplicatorException: The request included message batch larger than the configured segment size on the server. Topic: test, Partition: 1
```
**Soluzione**
Affinché Replicator possa procedere senza errori, la configurazione segment.bytes del cluster di destinazione deve avere almeno le dimensioni del batch (1 MB). Aggiornate il file segment.bytes del cluster di destinazione in modo che sia almeno 1048576 (1 MB). [Per informazioni su questa operazione, consulta segment.bytes.](https://kafka.apache.org/documentation/#topicconfigs_segment.bytes)
**Nota**
Se la ReplicatorFailure metrica continua a emettere valori diversi da zero dopo aver applicato queste soluzioni, ripeti la procedura di risoluzione dei problemi finché la metrica non emette un valore pari a zero.
# Best practice per l'utilizzo del replicatore MSK
Questa sezione illustra le best practice e le strategie di implementazione più comuni per l'utilizzo di Amazon MSK Replicator.
**Contents**
+ [Gestione della velocità di trasmissione effettiva del replicatore MSK utilizzando le quote Kafka](#msk-replicator-manage-throughput-kafka-quotas)
+ [Impostazione del periodo di conservazione dei cluster](#msk-replicator-retention-period)
## Gestione della velocità di trasmissione effettiva del replicatore MSK utilizzando le quote Kafka
Poiché il replicatore MSK funge da consumatore per il cluster di origine, la replica può causare la limitazione della larghezza di banda della rete di altri consumatori sul cluster di origine. L'entità della limitazione della larghezza di banda della rete dipende dalla capacità di lettura disponibile sul cluster di origine e dalla velocità di trasmissione effettiva dei dati da replicare. Ti consigliamo di fornire una capacità identica per i cluster di origine e di destinazione e di tenere conto della velocità di trasmissione effettiva di replica nel calcolo della capacità necessaria.
È inoltre possibile impostare quote Kafka per il replicatore sui cluster di origine e di destinazione per controllare la capacità che il replicatore MSK può utilizzare. Si consiglia di specificare una quota di larghezza di banda della rete. Una quota di larghezza di banda della rete definisce una soglia di velocità di byte, espressa in byte al secondo, per uno o più client che condividono una quota. Questa quota è definita per singolo broker.
Segui questi passaggi per applicare una quota.
1. Recupera la stringa del server di bootstrap per il cluster di origine. Per informazioni, consulta [Ottieni i broker bootstrap per un cluster Amazon MSK](msk-get-bootstrap-brokers.md).
1. Recupera il ruolo di esecuzione del servizio (SER) utilizzato dal replicatore MSK. Questo è il SER che hai utilizzato per una richiesta `CreateReplicator`. Puoi anche estrarre il SER dalla DescribeReplicator risposta di un Replicator esistente.
1. Utilizzando gli strumenti della CLI di Kafka, esegui il seguente comando sul cluster di origine.
```
./kafka-configs.sh --bootstrap-server --alter --add-config 'consumer_byte_
rate=' --entity-type users --entity-name arn:aws:sts:::assumed-role// --command-config
```
1. Dopo aver eseguito il comando precedente, verifica che il parametro `ReplicatorThroughput` non superi la quota impostata.
Nota che se riutilizzi un ruolo di esecuzione del servizio tra più replicatori MSK, questi sono tutti soggetti a questa quota. Se desideri mantenere quote separate per il replicatore, utilizza ruoli di esecuzione del servizio separati.
Per ulteriori informazioni sull'utilizzo dell'autenticazione IAM di MSK con le quote, consulta la pagina [Multi-tenancy Apache Kafka clusters in Amazon MSK with IAM access control and Kafka Quotas – Part 1](https://aws.amazon.com/blogs/big-data/multi-tenancy-apache-kafka-clusters-in-amazon-msk-with-iam-access-control-and-kafka-quotas-part-1/).
**avvertimento**
L'impostazione di un valore consumer\$1byte\$1rate estremamente basso può causare comportamenti inaspettati da parte del replicatore MSK.
## Impostazione del periodo di conservazione dei cluster
È possibile impostare il periodo di conservazione dei log sia per i cluster MSK assegnati sia per quelli serverless. Il periodo di conservazione consigliato è di 7 giorni. Vedi [Modifiche alla configurazione del cluster](msk-replicator-serverless-requirements.md#msk-replicator-config-changes) o [Configurazione del cluster MSK Serverless supportata](msk-replicator-serverless-requirements.md).