Fase 4: Creare un argomento nel MSK cluster Amazon - 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à.

Fase 4: Creare un argomento nel MSK cluster Amazon

In questo passaggio di Getting Started Using Amazon MSK, installi le librerie e gli strumenti client di Apache Kafka sul computer client, quindi crei un argomento.

avvertimento

I numeri di versione di Apache Kafka utilizzati in questo tutorial sono solo degli esempi. Ti consigliamo di utilizzare la stessa versione del client della versione del cluster. MSK In una versione precedente del client potrebbero mancare alcune funzionalità e correzioni di bug critici.

Per trovare la versione del tuo MSK cluster

  1. Vai a https://eu-west-2.console.aws.amazon.com/msk/

  2. Seleziona il cluster MSK.

  3. Prendi nota della versione di Apache Kafka utilizzata nel cluster.

  4. Sostituisci le istanze dei numeri di MSK versione di Amazon in questo tutorial con la versione ottenuta nel passaggio 3.

Per creare un argomento sul computer client

  1. Apri la EC2 console Amazon all'indirizzo https://console.aws.amazon.com/ec2/.

  2. Nel pannello di navigazione, seleziona Instances (Istanze). Quindi seleziona la casella di controllo accanto al nome del computer client che hai creato in Passaggio 3: creazione di un computer client.

  3. Scegliere Actions (Operazioni), quindi selezionare Connect (Connetti). Segui le istruzioni riportate nella console per connetterti al computer client.

  4. Installare Java sul computer client eseguendo il seguente comando:

    sudo yum -y install java-11

  5. Eseguire il seguente comando per scaricare Apache Kafka. 

    wget https://archive.apache.org/dist/kafka/{YOUR MSK VERSION}/kafka_2.13-{YOUR MSK VERSION}.tgz
    Nota

    Se desideri utilizzare un sito mirror diverso da quello utilizzato in questo comando, puoi sceglierne uno diverso sul sito Web di Apache .

  6. Esegui il comando seguente nella directory in cui hai scaricato il TAR file nel passaggio precedente.

    tar -xzf kafka_2.13-{YOUR MSK VERSION}.tgz

  7. Vai alla kafka_2.13-{YOUR MSK VERSION}/libs directory, quindi esegui il seguente comando per scaricare il MSK IAM JAR file Amazon. Amazon MSK IAM JAR consente alla macchina client di accedere al cluster.

    wget https://github.com/aws/aws-msk-iam-auth/releases/download/v1.1.1/aws-msk-iam-auth-1.1.1-all.jar

  8. Vai alla directory kafka_2.13-{YOUR MSK VERSION}/bin. Copia le impostazioni delle proprietà seguenti e incollale in un nuovo file. Assegna al file il nome client.properties e salvalo.

    security.protocol=SASL_SSL
sasl.mechanism=AWS_MSK_IAM
sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required;
sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler

  9. Apri la MSK console Amazon all'indirizzohttps://console.aws.amazon.com/msk/.

  10. Attendi che lo stato del cluster diventi Attivo. Questo processo potrebbe richiedere diversi minuti. Dopo che lo stato diventa Attivo, scegli il nome del cluster. Verrà visualizzata una pagina contenente il riepilogo del cluster.

  11. Scegli Visualizza le informazioni sul client.

  12. Copia la stringa di connessione per l'endpoint privato.

    Otterrai tre endpoint per ciascuno dei broker. È richiesto un solo endpoint del broker per il passaggio successivo.

  13. Esegui il comando seguente, sostituendolo BootstrapServerString con uno degli endpoint del broker ottenuti nel passaggio precedente.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server BootstrapServerString --command-config client.properties --replication-factor 3 --partitions 1 --topic MSKTutorialTopic

    Se il comando va a buon fine, viene visualizzato il seguente messaggio: Created topic MSKTutorialTopic.

Fase successiva

Passaggio 5: produzione e utilizzo di dati