Crea plugin personalizzati - 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 plugin personalizzati

Un plugin è una AWS risorsa che contiene il codice che definisce la logica del connettore. Quando si crea il plug-in, si carica un file JAR (o un file ZIP che contiene uno o più file JAR) in un bucket S3 e si specifica la posizione del bucket. Quando il plugin viene creato, MSK Connect copia il contenuto dell'oggetto S3 in quel momento. Non mantiene un collegamento all'oggetto S3, quindi eventuali modifiche successive all'oggetto non influiranno sul plugin o sui suoi connettori. Quando si crea un connettore, si specifica il plug-in che si desidera che MSK Connect utilizzi. La relazione tra i plugin e i connettori è one-to-many: puoi creare uno o più connettori dallo stesso plugin.

Nota

I plugin personalizzati non possono essere aggiornati sul posto. Per utilizzare una nuova versione del codice del plug-in, eliminate tutti i connettori che fanno riferimento al plug-in, eliminate il plug-in e quindi ricreatelo.

Pacchettizzazione delle dipendenze per plugin personalizzati

Ti consigliamo di includere tutti i file JAR e le dipendenze necessari per il tuo plugin. Package del connettore in uno dei seguenti formati:

  • Un file ZIP che contiene tutti i file JAR e le dipendenze necessari per il plugin.

  • Un singolo uber JAR che contiene tutti i file di classe per il plugin e le sue dipendenze.

Il mancato raggruppamento delle dipendenze del plug-in può influire sulla disponibilità o sulla compatibilità nell'ambiente di runtime e causare errori imprevisti.

Per informazioni su come sviluppare il codice per un connettore, consulta la pagina Connector Development Guide nella documentazione di Apache Kafka.

Creazione di un plug-in personalizzato utilizzando il Console di gestione AWS

  1. Apri la console Amazon MSK all'indirizzo https://console.aws.amazon.com/msk/.

  2. Nel riquadro a sinistra, in MSK Connect, scegli Plug-in personalizzati.

  3. Scegli Crea plug-in personalizzato.

  4. Seleziona Sfoglia S3.

  5. Nell'elenco dei bucket S3, scegli il bucket contenente il file JAR o ZIP per il plug-in.

  6. Nell'elenco degli oggetti, seleziona la casella a sinistra del file JAR o ZIP per il plug-in, quindi seleziona Scegli.

  7. Scegli Crea plug-in personalizzato.

Per utilizzare l'API MSK Connect per creare un plug-in personalizzato, vedere CreateCustomPlugin.