Consulta i connettori supportati per Application Integration.

Trigger di Apache Kafka

Anteprima - Apache Kafka trigger

Questa funzionalità è soggetta ai "Termini delle Offerte pre-GA" nella sezione Termini generali del servizio dei Termini specifici dei servizi. Le funzionalità pre-GA sono disponibili "così come sono" e potrebbero avere un supporto limitato. Per saperne di più, consulta le descrizioni della fase di lancio.

Il trigger di Apache Kafka è un trigger di evento connettore che consente di richiamare un'integrazione basata sugli eventi Apache Kafka a cui hai sottoscritto la connessione nella connessione Apache Kafka.

Importante: Integration Connectors è un componente fatturabile di Google Cloud. Per informazioni sui costi e sui costi dell'utilizzo di Integration Connectors, vedi Prezzi di Integration Connectors.

Prima di iniziare

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

• Amministratore connettori (roles/connectors.admin)

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

Concedi i seguenti ruoli IAM all'account di servizio che vuoi utilizzare per il trigger di Apache Kafka:

• Invoker di Application Integration (roles/integrations.integrationInvoker)

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

Limitazione

Il trigger di Apache Kafka è soggetto alle seguenti limitazioni:

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

Aggiungi il trigger di Apache Kafka

Per aggiungere un trigger di Apache Kafka alla tua integrazione, segui questi passaggi:

1. Nella console Google Cloud, vai alla pagina Application Integration.

   Vai ad Application Integration

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

   Viene visualizzata la pagina Integrations List (Elenco delle 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 saperne di più, 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 dell'integrazione.
      Nota: l'opzione per selezionare un account di servizio viene visualizzata solo se hai abilitato la governance dell'integrazione per la regione selezionata.
   4. Fai clic su Crea.

   L'integrazione viene aperta nell'editor dell'integrazione.

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

Per configurare il trigger di 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 di una connessione in linea.

Configura il trigger di Apache Kafka utilizzando una connessione esistente

Puoi configurare il trigger di Apache Kafka utilizzando una connessione Apache Kafka esistente in Integration Connectors. Tieni presente che il trigger di Apache Kafka è un trigger di evento connettore, pertanto puoi utilizzare solo una connessione Apache Kafka con la sottoscrizione di eventi abilitata per configurare il trigger.

Per informazioni su come configurare un trigger di Apache Kafka utilizzando una nuova connessione Apache Kafka, consulta Configurare un trigger 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 del trigger.
2. Fai clic su Configura trigger.
3. Fornisci i seguenti dettagli di configurazione nella pagina Editor trigger evento connettore:
   .
   1. Regione:seleziona la regione della connessione Apache Kafka.
   2. Connessione:seleziona la connessione Apache Kafka che vuoi utilizzare.

      Application Integration mostra solo le connessioni Apache Kafka attive e con una sottoscrizione agli eventi abilitata.

   3. Nome argomento: inserisci il nome dell'argomento.
   4. ID gruppo consumer: facoltativamente, inserisci l'ID gruppo consumer che specifica il nome del gruppo di consumer a cui appartiene il consumer Kafka.
   5. Partizione: inserisci la partizione se vuoi sottoscrivere una particolare partizione. Le partizioni sono un modo per suddividere un argomento in più parti e archiviare ogni parte su un nodo diverso del cluster.
   6. Offset iniziale: seleziona la strategia di reimpostazione dell'offset.
      • Se selezioni il meno recente, la connessione consuma i messaggi non consumati, inclusi quelli prodotti prima della durata del gruppo di consumer.
      • Se selezioni più recente, la connessione utilizza i messaggi prodotti dopo la creazione del gruppo di consumer.
   7. Account di servizio: seleziona un account di servizio con i ruoli IAM richiesti per il trigger di Apache Kafka.
4. Fai clic su Fine.

Configura il trigger di Apache Kafka utilizzando una nuova connessione

Per configurare il trigger di Apache Kafka utilizzando una nuova connessione Apache Kafka, segui questi passaggi:

1. Fai clic sull'elemento trigger Apache Kafka nell'editor di integrazione per aprire il riquadro di configurazione del trigger.
2. Fai clic su Configura trigger Apache Kafka.
3. Salta 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 Posizione, scegli la località 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 sulla nuova connessione Apache Kafka:
   .
   1. Versione 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 contenere più di 63 caratteri.
   3. (Facoltativo) Descrizione : inserisci una descrizione per la connessione.
   4. (Facoltativo) Abilita Cloud Logging: seleziona questa casella di controllo per archiviare tutti i dati di log della connessione.
   5. Account di servizio: seleziona un account di servizio con i ruoli IAM richiesti per la connessione Apache Kafka.
   6. L'opzione Abilita sottoscrizione agli eventi, entità e azioni è selezionata per impostazione predefinita per la connessione Apache Kafka.
      Nota: questo connettore non supporta la Enable only event subscription.
   7. Schema di rilevamento del tipo : seleziona MessageOnly.
   8. Servizio di registro di sistema: il servizio di registro degli schemi utilizzato per lavorare con gli schemi degli argomenti.
   9. Tipo di registro: il tipo di schema specificato per un argomento specifico.
   10. Versione del Registro di sistema: versione dello schema letta da RegistryUrl per l'argomento specificato.
   11. Utente di registro: il valore del nome utente o della chiave di accesso da autorizzare con il server specificato in RegistryUrl.
   12. Password del Registro di sistema: secret di Secret Manager contenente il valore della password/della chiave segreta da autorizzare con il server specificato in RegistryUrl.
   13. Facoltativamente, 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. Sono necessari più nodi per elaborare più transazioni per una connessione e, per elaborare meno transazioni. Per comprendere 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 migliore disponibilità) e il numero massimo di nodi è impostato su 50.

   Nota: puoi personalizzare i valori del nodo di connessione solo se un cliente con pagamento a consumo.
   14. Facoltativamente, fai clic su + AGGIUNGI ETICHETTA per aggiungere un'etichetta alla connessione sotto forma di coppia chiave-valore.
   15. Abilita SSL: questo campo consente di impostare se SSL è abilitato.
   16. Fai clic su Avanti.
7. Nella sezione Destinazioni, inserisci i dettagli dell'host remoto (sistema di backend) 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 Collegamento endpoint dall'elenco, quindi seleziona il collegamento dell'endpoint richiesto. dall'elenco Allegato endpoint.
        Nota: per capire come creare un collegamento dell'endpoint, vedi Collegamento servizio PSC e l'allegato endpoint. Dopo hanno creato il collegamento dell'endpoint, sarà visibile nell'elenco Allegato endpoint.

      Se vuoi stabilire una connessione pubblica ai tuoi sistemi di backend con maggiore sicurezza, puoi valuta la possibilità di configurare una rete statico in uscita indirizzi IP per le tue connessioni, quindi configura le regole del firewall per inserire nella lista consentita solo gli indirizzi IP statici specifici.

      Per inserire altre destinazioni, 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 di Apache Kafka da utilizzare per la connessione.
        • Password: il secret di Secret Manager contenente la password associata al nome utente di Apache Kafka.
        • Schema di autenticazione: lo schema utilizzato per l'autenticazione.

          I seguenti schemi di autenticazione sono supportati dalla connessione Apache Kafka:

          • Normale
          • 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 i messaggi non recapitabili, 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. Verifica: controlla i dettagli della connessione e dell'autenticazione.
12. Fai clic su Crea.

Output trigger

Il trigger di Apache Kafka richiede un paio di minuti per completare la configurazione della sottoscrizione dell'evento. Puoi visualizzare lo stato della tua sottoscrizione all'evento nel riquadro di configurazione del trigger in Dettagli sottoscrizione all'evento.

Il trigger di Apache Kafka indica lo stato della sottoscrizione di un evento utilizzando i seguenti stati:

• Creating: indica che l'attivatore sta eseguendo la sottoscrizione alla sottoscrizione all'evento.
• Active: indica che l'attivatore ha sottoscritto correttamente la sottoscrizione a un evento.
• Error: indica che si è verificato un problema con la sottoscrizione all'evento configurato.

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

Variabile di output del trigger

Per ogni evento, il trigger di Apache Kafka genera un ConnectorEventPayload (in formato JSON) che puoi utilizzare nelle attività downstream. L'output avrà il payload del tuo 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"
 }

Visualizza le iscrizioni agli eventi

Per visualizzare e gestire tutte le sottoscrizioni agli eventi associate a una connessione in Integration Connectors, segui questi passaggi:

1. Vai a Integration Connectors > (Connettori di integrazione) Connessioni.

   Vai alla pagina Connessioni

2. Fai clic sulla connessione per la quale vuoi visualizzare gli abbonamenti.
3. Fai clic sulla scheda Iscrizioni agli eventi.

   Vengono visualizzate tutte le iscrizioni agli eventi per la connessione.

Modifica trigger Apache Kafka

Puoi modificare un trigger di Apache Kafka per cambiare o aggiornare la configurazione della connessione e i dettagli della sottoscrizione dell'evento.

Importante:quando modifichi o modifichi un trigger Apache Kafka, puoi mantenere la sottoscrizione agli eventi configurata in precedenza associata al trigger oppure eliminarla. L'eliminazione di un abbonamento all'evento influirà su tutte le integrazioni pubblicate che utilizzano l'abbonamento all'evento.

Per modificare un trigger di Apache Kafka, segui questi passaggi:

1. Fai clic sull'elemento trigger Apache Kafka nell'editor di integrazione per aprire il riquadro di configurazione del trigger.
2. Fai clic su Configura trigger Apache Kafka.
3. Effettua le seguenti operazioni nella pagina Editor trigger evento connettore:
   .
   1. Per mantenere la sottoscrizione all'evento configurata in precedenza, fai clic su Conserva, altrimenti fai clic su Elimina.
      Avviso:l'eliminazione di un abbonamento all'evento influirà su tutte le integrazioni pubblicate che utilizzano l'abbonamento all'evento. Questa attività non può essere annullata.
   2. Aggiorna la configurazione della connessione e i dettagli della sottoscrizione all'evento come preferisci.
   3. Fai clic su Fine.

Puoi visualizzare i dettagli aggiornati della connessione e della sottoscrizione agli eventi nel riquadro di configurazione del trigger in Dettagli abbonamento agli eventi.