Avvio rapido: Trasmettere i dati con Hub eventi di Azure e Apache Kafka

1. Abilitare l'identità gestita assegnata dal sistema per la macchina virtuale. Per informazioni su come configurare un'identità gestita su una VM, vedere Configurare identità gestite per risorse di Azure in una macchina virtuale tramite il portale di Azure. Le identità gestite per le risorse di Azure offrono servizi di Azure con un'identità gestita automaticamente in Microsoft Entra ID. È possibile usare questa identità per l'autenticazione in qualsiasi servizio che supporta l'autenticazione di Microsoft Entra senza dover immettere le credenziali nel codice.

   

2. Usando la pagina Controllo di accesso dello spazio dei nomi di Hub eventi creato, assegnare il ruolo Proprietario dei dati di Hub eventi di Azure all'identità gestita della VM. Hub eventi di Azure supporta l'utilizzo di Microsoft Entra ID per autorizzare le richieste alle risorse di Hub eventi. Con Microsoft Entra ID, è possibile usare il controllo degli accessi in base al ruolo di Azure per concedere autorizzazioni a un'entità di sicurezza, che può essere un utente o un'entità servizio dell'applicazione.

   1. Passare allo spazio dei nomi degli hub eventi nel portale di Azure. Passare a "Controllo di accesso (IAM)" nella struttura di navigazione di sinistra.

   2. Selezionare + Aggiungi, quindi Add role assignment.

      

   3. Nella scheda Ruolo, selezionare Proprietario dei dati di Hub eventi di Azure e selezionare il pulsante Avanti.

      

   4. Alla scheda Membri, selezionare Identità gestita nella sezione Assegnare accesso a.

   5. Selezionare il link +Seleziona membri.

   6. Alla pagina Selezionare identità gestite, seguire questi passaggi:

      1. Selezionare la sottoscrizione di Azure che include la VM.

      2. Per Identità gestita, selezionare Macchina virtuale

      3. Selezionare l'identità gestita della macchina virtuale.

      4. Selezionare Seleziona nella parte inferiore della pagina.

         

   7. Selezionare Rivedi + Assegna.

      

3. Riavviare la macchina virtuale e accedere nuovamente alla VM per cui è stata configurata l'identità gestita.

4. Clonare gli Hub eventi di Azure per il repository di Kafka.

5. Accedere a azure-event-hubs-for-kafka/tutorials/oauth/java/managedidentity/consumer.

6. Passare alla cartella src/main/resources/ e aprire consumer.config. Sostituire namespacename con il nome dello spazio dei nomi di Hub eventi.

   bootstrap.servers=NAMESPACENAME.servicebus.windows.net:9093
   security.protocol=SASL_SSL
   sasl.mechanism=OAUTHBEARER
   sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;
   sasl.login.callback.handler.class=CustomAuthenticateCallbackHandler;
   

   Nota

   Tutti gli esempi di OAuth per Hub eventi per Kafka sono disponibili qui.

7. Tornare alla cartella Consumer in cui si trova il file pom.xml ed eseguire il codice consumer gli eventi del processo dall'Hub eventi usando i client Kafka:

   mvn clean package
   mvn exec:java -Dexec.mainClass="TestConsumer"                                    
   

8. Avviare un'altra finestra del prompt dei comandi e passare a azure-event-hubs-for-kafka/tutorials/oauth/java/managedidentity/producer.

9. Passare alla cartella src/main/resources/ e aprire producer.config. Sostituire mynamespace con il nome dello spazio dei nomi di Hub eventi.

10. Tornare alla cartella Producer, dove si trova il file pom.xml, eseguire il codice producer e tramettere eventi in Hub eventi:

    mvn clean package
    mvn exec:java -Dexec.mainClass="TestProducer"                                    
    

    Si dovrebbero vedere i messaggi sugli eventi inviati nella finestra producer. Ora, controllare la finestra dell'app consumer per vedere i messaggi che riceve dall'Hub eventi.

    

1. Clonare gli Hub eventi di Azure per il repository di Kafka.

2. Passare a azure-event-hubs-for-kafka/quickstart/java/consumer.

3. Aggiornare i dettagli di configurazione per il consumer in src/main/resources/consumer.config come segue:

   bootstrap.servers=NAMESPACENAME.servicebus.windows.net:9093
   security.protocol=SASL_SSL
   sasl.mechanism=PLAIN
   sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
   

   Importante

   Sostituire {YOUR.EVENTHUBS.CONNECTION.STRING} con la stringa di connessione per lo spazio dei nomi di Hub eventi. Per istruzioni su come ottenere la stringa di connessione, vedere Ottenere una stringa di connessione ad Hub eventi. Ecco un esempio di configurazione: sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=XXXXXXXXXXXXXXXX";

4. Eseguire il codice consumer ed elaborare gli eventi dell'hub eventi con i client Kafka:

   mvn clean package
   mvn exec:java -Dexec.mainClass="TestConsumer"
   

5. Passare a azure-event-hubs-for-kafka/quickstart/java/producer.

6. Aggiornare i dettagli di configurazione per il producer in src/main/resources/producer.config come segue:

   bootstrap.servers=NAMESPACENAME.servicebus.windows.net:9093
   security.protocol=SASL_SSL
   sasl.mechanism=PLAIN
   sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
   

   Importante

   Sostituire {YOUR.EVENTHUBS.CONNECTION.STRING} con la stringa di connessione per lo spazio dei nomi di Hub eventi. Per istruzioni su come ottenere la stringa di connessione, vedere Ottenere una stringa di connessione ad Hub eventi. Ecco un esempio di configurazione: sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=XXXXXXXXXXXXXXXX";

7. Eseguire il codice del producer e trasmettere eventi in Hub eventi:

   mvn clean package
   mvn exec:java -Dexec.mainClass="TestProducer"
   

Se il cluster Kafka di Hub eventi include eventi, ora si dovrebbe iniziare a riceverli dal consumer.