Crea una macchina client per accedere al cluster MSK Serverless - 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à.

Crea una macchina client per accedere al cluster MSK Serverless

In questo passaggio, eseguirai due attività. La prima operazione consiste nel creare un'EC2istanza Amazon da utilizzare come macchina client Apache Kafka. La seconda attività consiste nell'installare gli strumenti Java e Apache Kafka sul computer.

Per creare un computer client

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

  2. Scegliere Launch Instance (Avvia istanza).

  3. Inserisci un Nome descrittivo per il computer client, ad esempio msk-serverless-tutorial-client.

  4. Lascia Amazon Linux 2 AMI (HVM) - Kernel 5.10, SSD Volume Type selezionato per il tipo Amazon Machine Image (AMI).

  5. Lascia selezionato il tipo di istanza t2.micro.

  6. In Coppia di chiavi (accesso), scegli Crea una nuova coppia di chiavi. Inserisci MSKServerlessKeyPair per Nome coppia di chiavi. Quindi scegli Scarica coppia di chiavi. In alternativa, è possibile utilizzare una coppia di chiavi esistente.

  7. Per Impostazioni di rete, scegli Modifica.

  8. In VPC, inserisci l'ID del cloud privato virtuale (VPC) per il tuo cluster serverless. Si VPC basa sul VPC servizio Amazon il cui ID è stato salvato dopo la creazione del cluster.

  9. Per Sottorete, scegli la sottorete di cui hai salvato l'ID dopo aver creato il cluster.

  10. Per Firewall (gruppi di sicurezza), seleziona il gruppo di sicurezza associato al cluster. Questo valore funziona se il gruppo di sicurezza ha una regola in entrata che consente il traffico dal gruppo di sicurezza verso sé stesso. Con questa regola, i membri dello stesso gruppo di sicurezza possono comunicare tra loro. Per ulteriori informazioni, consulta le regole dei gruppi di sicurezza nella Amazon VPC Developer Guide.

  11. Espandi la sezione Dettagli avanzati e scegli il IAM ruolo per cui hai creatoCrea un IAM ruolo per gli argomenti sul cluster MSK Serverless.

  12. Scegli Avvia.

  13. Nel riquadro di navigazione a sinistra, scegliere Instances (Istanze). Quindi scegli la casella di controllo nella riga che rappresenta l'EC2istanza Amazon appena creata. D'ora in avanti, chiameremo questa istanza computer client.

  14. Scegli Connetti e segui le istruzioni per connetterti al computer client.

Configurazione degli strumenti client Apache Kafka sul computer client

  1. Per installare Java, esegui il comando seguente sul computer client:

    sudo yum -y install java-11

  2. Per recuperare gli strumenti di Apache Kafka necessari per creare argomenti e inviare dati, esegui i seguenti comandi:

    wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz
    tar -xzf kafka_2.12-2.8.1.tgz

  3. Vai alla kafka_2.12-2.8.1/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

  4. Vai alla directory kafka_2.12-2.8.1/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

Fase successiva

Crea un argomento su Apache Kafka