Passaggio 4: creazione di un argomento

In questo passaggio della Guida introduttiva all'utilizzo di Amazon MSK, installi librerie e strumenti client di Apache Kafka sul computer client e 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.

Individuazione della versione del cluster MSK

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 versione di Amazon MSK in questo tutorial con la versione ottenuta nel passaggio 3.

Per creare un argomento sul computer client

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

2. Nel riquadro di navigazione, seleziona 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. Eseguire il comando seguente nella directory in cui è stato scaricato il file TAR nella fase precedente.

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

7. Vai alla directory kafka_2.13-{YOUR MSK VERSION}/libs, quindi esegui il comando per scaricare il file JAR IAM di Amazon MSK. Il file JAR IAM di Amazon MSK consente al computer 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 console Amazon MSK all'indirizzo https://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 BootstrapServerStringcon 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