Consulta i connettori supportati per Application Integration.

Trigger Apache Kafka

Preview — Apache Kafka trigger

This feature is subject to the "Pre-GA Offerings Terms" in the General Service Terms section of the Service Specific Terms. Pre-GA features are available "as is" and might have limited support. For more information, see the launch stage descriptions.

L'attivatore Apache Kafka è un attivatore evento del connettore che ti consente di invocare un'integrazione in base agli eventi Apache Kafka a cui hai effettuato l'iscrizione nella connessione Apache Kafka.

Importante:Integration Connectors è un componente fatturabile di Google Cloud. Per informazioni sui costi e sugli addebiti relativi all'utilizzo di Integration Connectors, consulta la pagina Prezzi di Integration Connectors.

Prima di iniziare

Se prevedi di creare o configurare una nuova connessione per l'attivatore Apache Kafka, assicurati di disporre del seguente ruolo Identity and Access Management (IAM) nel progetto:

• Connector Admin (roles/connectors.admin)

Per informazioni sulla concessione dei ruoli, consulta Gestire l'accesso.

Concedi i seguenti ruoli IAM al service account che vuoi utilizzare per l'attivatore Apache Kafka:

• Application Integration Invoker (roles/integrations.integrationInvoker)

Per informazioni sulla concessione di ruoli a un account di servizio, vedi Gestire l'accesso agli account di servizio.

Limitazione

L'attivatore Apache Kafka è soggetto alle seguenti limitazioni:

• Supporta il protocollo di sicurezza SASL_SSL per le sottoscrizioni agli eventi.
• Non supporta mTLS per le iscrizioni agli eventi.

Aggiungi l'attivatore Apache Kafka

Per aggiungere un trigger Apache Kafka all'integrazione, segui questi passaggi:

1. Nella console Google Cloud, vai alla pagina Integrazione delle applicazioni.

   Vai ad Application Integration

2. Nel menu di navigazione, fai clic su Integrations (Integrazioni).

   Viene visualizzata la pagina Elenco integrazioni, che elenca tutte le integrazioni disponibili nel progetto Google Cloud.

3. Seleziona un'integrazione esistente o fai clic su Crea integrazione per crearne una nuova.

   Se stai creando una nuova integrazione:

   1. Inserisci un nome e una descrizione nel riquadro Crea integrazione.
   2. Seleziona una regione per l'integrazione.
      Nota: il menu a discesa Regioni elenca solo le regioni di cui è stato eseguito il provisioning nel progetto Google Cloud. Per eseguire il provisioning di una nuova regione, fai clic su Attiva regione. Per ulteriori informazioni, consulta Attivare una nuova regione.
   3. Seleziona un account di servizio per l'integrazione. Puoi modificare o aggiornare i dettagli dell'account di servizio di un'integrazione in qualsiasi momento dal riquadro Riepilogo dell'integrazione nella barra degli strumenti di integrazione.
      Nota: l'opzione per selezionare un service account viene visualizzata solo se hai attivato la governance dell'integrazione per la regione selezionata.
   4. Fai clic su Crea.

   Viene visualizzata l'integrazione nell'editor di integrazione.

4. Nella barra di navigazione dell'editor dell'integrazione, fai clic su Attivatori per visualizzare l'elenco degli attivatori disponibili.
5. Fai clic e posiziona l'elemento Trigger Apache Kafka nell'editor di integrazione.

Per configurare l'attivatore Apache Kafka, puoi utilizzare una connessione Apache Kafka esistente disponibile in Integration Connectors o creare una nuova connessione Apache Kafka utilizzando l'opzione di creazione della connessione in linea.

Configurare l'attivatore Apache Kafka utilizzando una connessione esistente

Puoi configurare l'attivatore Apache Kafka utilizzando una connessione Apache Kafka esistente in Integration Connectors. Tieni presente che l'attivatore Apache Kafka è un attivatore evento del connettore, pertanto puoi utilizzare solo una connessione Apache Kafka con l'iscrizione agli eventi abilitata per configurare l'attivatore.

Per informazioni su come configurare un attivatore Apache Kafka utilizzando una nuova connessione Apache Kafka, consulta Configurare l'attivatore Apache Kafka utilizzando una nuova connessione

Per configurare un trigger Apache Kafka utilizzando una connessione Apache Kafka esistente:

1. Fai clic sull'elemento Trigger Apache Kafka nell'editor di integrazione per aprire il riquadro di configurazione dell'attivatore.
2. Fai clic su Configura trigger.
3. Fornisci i seguenti dettagli di configurazione nella pagina Editor dell'attivatore evento del connettore:
   1. Regione:seleziona la regione della connessione Apache Kafka.
   2. Connessione:seleziona la connessione Apache Kafka che vuoi utilizzare.

      L'integrazione delle applicazioni mostra solo le connessioni Apache Kafka attive e con una sottoscrizione di eventi abilitata.

   3. Nome argomento: inserisci il nome dell'argomento.
   4. ID gruppo di consumer: se vuoi, inserisci l'ID gruppo di consumer che specifica il nome del gruppo di consumer a cui appartiene il consumer Kafka.
   5. Partizione: inserisci la partizione se vuoi abbonarti a una determinata partizione. Le partizioni consentono di suddividere un argomento in più parti e di archiviare ogni parte su un nodo diverso del cluster.
   6. Spostamento iniziale: seleziona la strategia di reimpostazione dello spostamento:
      • Se selezioni più recente, la connessione consuma i messaggi non consumati, inclusi i messaggi prodotti prima del ciclo di vita del gruppo di consumo.
      • Se selezioni più recente, la connessione utilizza i messaggi prodotti dopo la creazione del gruppo di consumatori.
   7. Account di servizio: seleziona un account di servizio con i ruoli IAM richiesti per l'attivatore Apache Kafka.
4. Fai clic su Fine.

Configura l'attivatore Apache Kafka utilizzando una nuova connessione

Per configurare l'attivatore Apache Kafka utilizzando una nuova connessione Apache Kafka, svolgi i seguenti passaggi:

1. Fai clic sull'elemento Trigger Apache Kafka nell'editor di integrazione per aprire il riquadro di configurazione dell'attivatore.
2. Fai clic su Configura trigger Apache Kafka.
3. Ignora il campo Regione.
4. Fai clic su Connessione e seleziona l'opzione Crea connessione dall'elenco. Viene visualizzato il riquadro Crea connessione.
5. Nel passaggio Località, scegli la posizione per la nuova connessione Apache Kafka:
   1. Regione:seleziona una regione dall'elenco.
   2. Fai clic su Avanti.
6. Nel passaggio Dettagli connessione, fornisci i dettagli della nuova connessione Apache Kafka:
   1. Versione del connettore:scegli una versione disponibile del connettore Apache Kafka dall'elenco.
   2. Nome connessione:inserisci un nome per la connessione Apache Kafka.
      Nota: i nomi delle connessioni devono soddisfare i seguenti criteri:

      • I nomi delle connessioni possono contenere lettere, numeri o trattini.
      • Le lettere devono essere minuscole.
      • I nomi delle connessioni devono iniziare con una lettera e terminare con una lettera o un numero.
      • I nomi delle connessioni non possono superare i 49 caratteri.
      • Per i connettori che supportano la sottoscrizione agli eventi, i nomi delle connessioni non possono iniziare con il prefisso "goog".
   3. (Facoltativo) Descrizione : inserisci una descrizione per la connessione.
   4. (Facoltativo) Attiva Cloud Logging:seleziona questa casella di controllo per archiviare tutti i dati dei log della connessione.
   5. Account di servizio: seleziona un account di servizio con i ruoli IAM richiesti per la connessione ad Apache Kafka.
   6. L'opzione Attiva sottoscrizioni, entità e azioni per l'evento è selezionata per impostazione predefinita per la connessione Apache Kafka.
      Nota: questo connettore non supporta l'opzione Enable only event subscription.
   7. Schema di rilevamento dei tipi: seleziona MessageOnly.
   8. Registry Service: il servizio Registry Schema utilizzato per lavorare con gli schemi degli argomenti.
   9. Tipo di registry: tipo di schema specificato per un argomento specifico.
   10. Versione del registry: versione dello schema letto da RegistryUrl per l'argomento specificato.
   11. Utente del registry: valore del nome utente o della chiave di accesso da autorizzare con il server specificato in RegistryUrl.
   12. Password del registry: segreto di Secret Manager contenente il valore della chiave della password/del segreto da autorizzare con il server specificato in RegistryUrl.
   13. (Facoltativo) Configura le impostazioni del nodo di connessione:
       • Numero minimo di nodi: inserisci il numero minimo di nodi di connessione.
       • Numero massimo di nodi: inserisci il numero massimo di nodi di connessione.

       Un nodo è un'unità (o una replica) di una connessione che elabora le transazioni. Per elaborare più transazioni per una connessione sono necessari più nodi e, al contrario, sono necessari meno nodi per elaborare meno transazioni. Per capire in che modo i nodi influiscono sui prezzi dei connettori, consulta Prezzi per i nodi di connessione. Se non inserisci alcun valore, per impostazione predefinita il numero minimo di nodi è impostato su 2 (per una maggiore disponibilità) e il numero massimo di nodi è impostato su 50.

   Nota: puoi personalizzare i valori dei nodi di connessione solo se sei un cliente con pagamento a consumo.
   14. Se vuoi, fai clic su + AGGIUNGI ETIQUETTA per aggiungere un'etichetta alla connessione sotto forma di coppia chiave/valore.
   15. Abilita SSL: questo campo imposta se SSL è attivo.
   16. Fai clic su Avanti.
7. Nella sezione Destinazioni, inserisci i dettagli del server di bootstrap Kafka a cui vuoi connetterti.
   1. Tipo di destinazione: seleziona un Tipo di destinazione.
      • Seleziona Indirizzo host dall'elenco per specificare il nome host o l'indirizzo IP della destinazione.
      • Se vuoi stabilire una connessione privata ai tuoi sistemi di backend, seleziona Allegato endpoint dall'elenco, quindi seleziona l'allegato endpoint richiesto dall'elenco Allegato endpoint.
        Nota: per capire come creare un collegamento endpoint, consulta Collegamento del servizio PSC e Collegamento endpoint. Una volta creato, il collegamento dell'endpoint sarà visibile nell'elenco Collegamento dell'endpoint.

      Se vuoi stabilire una connessione pubblica ai tuoi sistemi di backend con una maggiore sicurezza, puoi prendere in considerazione la configurazione di indirizzi IP statici in uscita per le tue connessioni, quindi configurare le regole del firewall in modo da inserire nella lista consentita solo gli indirizzi IP statici specifici.

      Per specificare altri server di bootstrap Kafka, fai clic su + AGGIUNGI DESTINAZIONE.

   2. Fai clic su Avanti.
8. Nella sezione Autenticazione, inserisci i dettagli di autenticazione.
   1. Seleziona un Tipo di autenticazione e inserisci i dettagli pertinenti.

      La connessione Apache Kafka supporta i seguenti tipi di autenticazione:

      • Nome utente e password
        • Nome utente: il nome utente Apache Kafka da utilizzare per la connessione.
        • Password: il segreto Secret Manager contenente la password associata al nome utente di Apache Kafka.
        • Schema di autenticazione: lo schema utilizzato per l'autenticazione.

          La connessione Apache Kafka supporta i seguenti schemi di autenticazione:

          • Semplice
          • SCRAM-SHA-1
          • SCRAM-SHA-256
      • Non disponibile

        Se vuoi utilizzare l'accesso anonimo, seleziona Non disponibile.

   2. Fai clic su Avanti.
9. Inserisci la configurazione dei messaggi non recapitabili. Se configuri la posta in arrivo, la connessione scrive gli eventi non elaborati nell'argomento Pub/Sub specificato. Inserisci i seguenti dettagli:
   1. ID progetto messaggi non recapitabili : l'ID progetto Google Cloud in cui hai configurato l'argomento Pub/Sub messaggi non recapitabili.
   2. Argomento messaggi non recapitabili : l'argomento Pub/Sub in cui vuoi scrivere i dettagli dell'evento non elaborato.
10. Fai clic su Avanti.
11. Rivedi: controlla i dettagli di connessione e autenticazione.
12. Fai clic su Crea.

Attiva l'output

L'attivatore Apache Kafka richiede un paio di minuti per completare la configurazione dell'iscrizione agli eventi. Puoi visualizzare lo stato dell'iscrizione agli eventi nel riquadro di configurazione dell'attivatore in Dettagli iscrizione eventi.

L'attivatore Apache Kafka indica lo stato di un abbonamento agli eventi utilizzando i seguenti stati:

• Creating: indica che l'attivatore si iscrive all'abbonamento all'evento.
• Active: indica che l'attivatore è stato sottoscritto correttamente per un abbonamento agli eventi.
• Error: indica che si è verificato un problema con l'abbonamento agli eventi configurato.

Oltre allo stato della sottoscrizione all'evento, la sezione Dettagli della sottoscrizione all'evento mostra anche altri dettagli, come la regione di connessione, il nome della connessione e il nome della sottoscrizione all'evento.

Variabile di output dell'attivatore

Per ogni evento, l'attivatore Apache Kafka genera una variabile di output ConnectorEventPayload (in formato JSON) che puoi utilizzare nelle attività a valle. La variabile di output avrà il payload dell'evento Apache Kafka. Ad esempio:

  {
    "message": "{\"key\":\"18\",\"topic\":\"test\",\"value\":\"hello world\",\"partition\":0,\"offset\":12,\"headers\":\"{}\",\"timestamp\":1712755076824,\"serializedMessagesize\":14}",
    "contentType": "text/plain"
 }

Visualizzare le iscrizioni agli eventi

Per visualizzare e gestire tutte le iscrizioni agli eventi associate a una connessione in Integration Connectors:

1. Vai alla pagina Connettori di integrazione > Connessioni.

   Vai alla pagina Connessioni

2. Fai clic sul collegamento per cui vuoi visualizzare gli abbonamenti.
3. Fai clic sulla scheda Abbonamenti agli eventi.

   Vengono visualizzati tutti gli abbonamenti agli eventi per la connessione.

Modifica l'attivatore Apache Kafka

Puoi modificare un attivatore Apache Kafka per cambiare o aggiornare la configurazione della connessione e i dettagli dell'iscrizione agli eventi.

Importante: quando modifichi o gestisci un attivatore Apache Kafka, puoi conservare l'iscrizione agli eventi configurata in precedenza associata all'attivatore oppure eliminarla. L'eliminazione di una sottoscrizione di eventi influirà su tutte le integrazioni pubblicate che la utilizzano.

Per modificare un trigger Apache Kafka:

1. Fai clic sull'elemento Trigger Apache Kafka nell'editor di integrazione per aprire il riquadro di configurazione dell'attivatore.
2. Fai clic su Configura trigger Apache Kafka.
3. Nella pagina Editor di trigger evento connettore:
   1. Per mantenere l'abbonamento agli eventi configurato in precedenza, fai clic su Mantieni, altrimenti fai clic su Elimina.
      Avviso: l'eliminazione di una sottoscrizione di eventi influirà su tutte le integrazioni pubblicate che la utilizzano. Questa attività non può essere annullata.
   2. Aggiorna la configurazione della connessione e i dettagli dell'iscrizione agli eventi come preferisci.
   3. Fai clic su Fine.

Puoi visualizzare i dettagli aggiornati della connessione e della sottoscrizione di eventi nel riquadro di configurazione dell'attivatore in Dettagli della sottoscrizione di eventi.

Quote e limiti

Per informazioni su quote e limiti, consulta Quote e limiti.

Passaggi successivi

• Scopri di più su tutte le attività e gli attivatori.
• Scopri come testare e pubblicare un'integrazione.
• Scopri di più sulla gestione degli errori.
• Scopri di più sui log di esecuzione dell'integrazione.