Benvenuto nella Amazon MSK Developer Guide - Amazon Managed Streaming per Apache Kafka
Che cos'è Amazon MSK?

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à.

Benvenuto nella Amazon MSK Developer Guide

Benvenuto nella Amazon MSK Developer Guide. I seguenti argomenti possono aiutarti a iniziare a usare questa guida, in base a ciò che stai cercando di fare.

Per i punti salienti, i dettagli del prodotto e i prezzi, consulta la pagina dei servizi di Amazon MSK.

Che cos'è Amazon MSK?

Amazon Managed Streaming for Apache Kafka (MSKAmazon) è un servizio completamente gestito che consente di creare ed eseguire applicazioni che utilizzano Apache Kafka per elaborare dati di streaming. Amazon MSK fornisce le operazioni del piano di controllo, come quelle per la creazione, l'aggiornamento e l'eliminazione dei cluster. Consente di utilizzare operazioni del piano dati Apache Kafka, come quelle per la produzione e il consumo di dati. Esegue versioni open-source di Apache Kafka. Ciò significa che le applicazioni, gli strumenti e i plugin esistenti dei partner e della comunità Apache Kafka sono supportati senza richiedere modifiche al codice dell'applicazione. Puoi usare Amazon MSK per creare cluster che utilizzano una qualsiasi delle versioni di Apache Kafka elencate di seguito. Versioni di Apache Kafka supportate

Questi componenti descrivono l'architettura di AmazonMSK:

  • Nodi broker: quando crei un MSK cluster Amazon, specifichi quanti nodi broker desideri che Amazon MSK crei in ogni zona di disponibilità. Il minimo è un broker per zona di disponibilità. Ogni zona di disponibilità dispone di una propria sottorete cloud privato virtuale (VPC). Amazon MSK Provisioned offre due tipi di broker: MSKBroker Amazon Standard eMSKBroker Amazon Express. In MSKServerless, MSK gestisce i nodi broker utilizzati per gestire il traffico e fornisce le risorse del server Kafka solo a livello di cluster.

  • ZooKeeper nodi: Amazon crea MSK anche i ZooKeeper nodi Apache per te. Apache ZooKeeper è un server open source che consente un coordinamento distribuito altamente affidabile.

  • KRaftcontroller: la community Apache Kafka è stata sviluppata KRaft per sostituire Apache per la gestione dei metadati nei cluster Apache ZooKeeper Kafka. In KRaft modalità, i metadati del cluster vengono propagati all'interno di un gruppo di controller Kafka, che fanno parte del cluster Kafka, anziché tra i nodi. ZooKeeper KRafti controller sono inclusi senza costi aggiuntivi per l'utente e non richiedono alcuna configurazione o gestione aggiuntiva da parte dell'utente.

    Nota

    A partire dalla versione 3.7.x di Apache KafkaMSK, è possibile creare cluster che utilizzano la modalità anziché la modalità. KRaft ZooKeeper

  • Produttori, consumatori e creatori di argomenti: Amazon MSK consente di utilizzare le operazioni del piano dati di Apache Kafka per creare argomenti e produrre e consumare dati.

  • Operazioni del cluster È possibile utilizzare il AWS Management Console, the AWS Command Line Interface (AWS CLI) o il APIs in per eseguire operazioni sul piano di controllo. SDK Ad esempio, puoi creare o eliminare un MSK cluster Amazon, elencare tutti i cluster in un account, visualizzare le proprietà di un cluster e aggiornare il numero e il tipo di broker in un cluster.

Amazon MSK rileva e ripristina automaticamente gli scenari di errore più comuni per i cluster, in modo che le applicazioni di produzione e consumo possano continuare le operazioni di scrittura e lettura con un impatto minimo. Quando Amazon MSK rileva un guasto del broker, mitiga l'errore o sostituisce il broker malsano o irraggiungibile con uno nuovo. Inoltre, ove possibile, riutilizza lo storage del broker precedente per ridurre i dati che devono essere replicati da Apache Kafka. L'impatto sulla disponibilità è limitato al tempo necessario MSK ad Amazon per completare il rilevamento e il ripristino. Dopo un ripristino, le applicazioni produttore e consumatore possono continuare a comunicare con gli stessi indirizzi IP del broker utilizzati prima dell'errore.