Operazioni di configurazione Amazon MSK - Amazon Managed Streaming per Apache Kafka

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

Operazioni di configurazione Amazon MSK

In questo argomento viene descritto come creare configurazioni MSK personalizzate e come eseguire operazioni su di esse. Per informazioni su come utilizzare configurazioni MSK per creare o aggiornare cluster, consulta Amazon MSK: come funziona.

Per creare una configurazione MSK

  1. Creare un file in cui specificare le proprietà di configurazione che si desidera impostare e i valori da assegnare alle stesse. Di seguito sono riportati i contenuti di un file di configurazione di esempio.

    auto.create.topics.enable = true zookeeper.connection.timeout.ms = 1000 log.roll.ms = 604800000
  2. Esegui quanto segueAWS CLIcomando e sostituzioneconfig-file-pathcon il percorso del file in cui hai salvato la configurazione nel passaggio precedente.

    Nota

    Il nome scelto per la configurazione deve corrispondere alla seguente espressione regolare: "^[0-9A-Za-z][0-9A-Za-z-]{0,}$".

    aws kafka create-configuration --name "ExampleConfigurationName" --description "Example configuration description." --kafka-versions "1.1.1" --server-properties fileb://config-file-path

    Di seguito è riportato un esempio di risposta corretta dopo l'esecuzione di questo comando.

    { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "CreationTime": "2019-05-21T19:37:40.626Z", "LatestRevision": { "CreationTime": "2019-05-21T19:37:40.626Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "ExampleConfigurationName" }
  3. Il comando precedente restituisce un Amazon Resource Name (ARN) per la nuova configurazione. Salvare questo ARN perché occorre per fare riferimento a questa configurazione in altri comandi. Se perdi l'ARN di configurazione, puoi elencare tutte le configurazioni nel tuo account per ritrovarlo.

Per aggiornare una configurazione MSK

  1. Crea un file in cui specifichi le proprietà di configurazione che desideri aggiornare e i valori che desideri assegnare loro. Di seguito sono riportati i contenuti di un file di configurazione di esempio.

    auto.create.topics.enable = true zookeeper.connection.timeout.ms = 1000 min.insync.replicas = 2
  2. Esegui quanto segueAWS CLIcomando e sostituzioneconfig-file-pathcon il percorso del file in cui hai salvato la configurazione nel passaggio precedente.

    Sostituisciconfigurazione-arncon l'ARN ottenuto al momento della creazione della configurazione. Se non hai salvato l'ARN quando hai creato la configurazione, puoi usare illist-configurationscomando per elencare tutte le configurazioni nel tuo account. La configurazione desiderata nell'elenco viene visualizzata nella risposta. L'ARN della configurazione viene visualizzato anche in tale elenco.

    aws kafka update-configuration --arn configuration-arn --description "Example configuration revision description." --server-properties fileb://config-file-path
  3. Di seguito è riportato un esempio di risposta corretta dopo l'esecuzione di questo comando.

    { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "LatestRevision": { "CreationTime": "2020-08-27T19:37:40.626Z", "Description": "Example configuration revision description.", "Revision": 2 } }

Per eliminare una configurazione MSK

La procedura seguente mostra come eliminare una configurazione che non è collegata a un cluster. Non puoi eliminare una configurazione collegata a un cluster.

  1. Per eseguire questo esempio, sostituisciconfigurazione-arncon l'ARN ottenuto al momento della creazione della configurazione. Se non hai salvato l'ARN quando hai creato la configurazione, puoi usare illist-configurationscomando per elencare tutte le configurazioni nel tuo account. La configurazione desiderata nell'elenco viene visualizzata nella risposta. L'ARN della configurazione viene visualizzato anche in tale elenco.

    aws kafka delete-configuration --arn configuration-arn
  2. Di seguito è riportato un esempio di risposta corretta dopo l'esecuzione di questo comando.

    { "arn": " arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "state": "DELETING" }

Per descrivere una configurazione MSK

  1. Il comando seguente restituisce i metadati sulla configurazione. Per ottenere una descrizione dettagliata della configurazione, eseguire describe-configuration-revision.

    Per eseguire questo esempio, sostituisciconfigurazione-arncon l'ARN ottenuto al momento della creazione della configurazione. Se non hai salvato l'ARN quando hai creato la configurazione, puoi usare illist-configurationscomando per elencare tutte le configurazioni nel tuo account. La configurazione desiderata nell'elenco viene visualizzata nella risposta. L'ARN della configurazione viene visualizzato anche in tale elenco.

    aws kafka describe-configuration --arn configuration-arn
  2. Di seguito è riportato un esempio di risposta corretta dopo l'esecuzione di questo comando.

    { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-abcd-1234-abcd-abcd123e8e8e-1", "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "KafkaVersions": [ "1.1.1" ], "LatestRevision": { "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "SomeTest" }

Per descrivere una revisione della configurazione MSK

Se si utilizza ildescribe-configurationcomando per descrivere una configurazione MSK, vengono visualizzati i metadati della configurazione. Per ottenere una descrizione della configurazione, usa il comando,describe-configuration-revision.

  • Esegui il seguente comando e sostituisciconfigurazione-arncon l'ARN ottenuto al momento della creazione della configurazione. Se non hai salvato l'ARN quando hai creato la configurazione, puoi usare illist-configurationscomando per elencare tutte le configurazioni nel tuo account. La configurazione desiderata nell'elenco visualizzato nella risposta. L'ARN della configurazione viene visualizzato anche in tale elenco.

    aws kafka describe-configuration-revision --arn configuration-arn --revision 1

    Di seguito è riportato un esempio di risposta corretta dopo l'esecuzione di questo comando.

    { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-abcd-1234-abcd-abcd123e8e8e-1", "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "Revision": 1, "ServerProperties": "YXV0by5jcmVhdGUudG9waWNzLmVuYWJsZSA9IHRydWUKCgp6b29rZWVwZXIuY29ubmVjdGlvbi50aW1lb3V0Lm1zID0gMTAwMAoKCmxvZy5yb2xsLm1zID0gNjA0ODAwMDAw" }

    Il valore diServerPropertiesè codificato con base64. Se si utilizza un decodificatore base64 (ad esempio https://www.base64decode.org/) per decodificarlo manualmente, si ottiene il contenuto del file di configurazione originale utilizzato per creare la configurazione personalizzata. In questo caso, si ottiene quanto segue:

    auto.create.topics.enable = true zookeeper.connection.timeout.ms = 1000 log.roll.ms = 604800000

Per elencare tutte le configurazioni MSK nell'account per la regione corrente

  • Esegui il seguente comando.

    aws kafka list-configurations

    Di seguito è riportato un esempio di risposta corretta dopo l'esecuzione di questo comando.

    { "Configurations": [ { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-abcd-1234-abcd-abcd123e8e8e-1", "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "KafkaVersions": [ "1.1.1" ], "LatestRevision": { "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "SomeTest" }, { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "CreationTime": "2019-05-03T23:08:29.446Z", "Description": "Example configuration description.", "KafkaVersions": [ "1.1.1" ], "LatestRevision": { "CreationTime": "2019-05-03T23:08:29.446Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "ExampleConfigurationName" } ] }