Criar plug-ins personalizados - Amazon Managed Streaming for Apache Kafka

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Criar plug-ins personalizados

Um plug-in é um AWS recurso que contém o código que define a lógica do conector. Você carrega um arquivo JAR (ou um arquivo ZIP contendo um ou mais arquivos JAR) em um bucket do S3 e especifica a localização do bucket ao criar o plug-in. Quando o plug-in é criado, o MSK Connect copia o conteúdo do objeto S3 naquele momento. Ele não mantém um link para o objeto S3, portanto, quaisquer modificações subsequentes no objeto não afetarão o plug-in ou seus conectores. Ao criar um conector, você especifica o plug-in que deseja que o MSK Connect use para ele. A relação dos plug-ins com os conectores é one-to-many: você pode criar um ou mais conectores do mesmo plug-in.

nota

Os plug-ins personalizados não podem ser atualizados no local. Para usar uma nova versão do código do plug-in, exclua todos os conectores que fazem referência ao plug-in, exclua o plug-in e recrie-o.

Pacote de dependências para plug-ins personalizados

Recomendamos que você inclua todos os arquivos e dependências JAR necessários para seu plug-in. Package seu conector como um dos seguintes:

  • Um arquivo ZIP que contém todos os arquivos JAR e dependências necessários para o plug-in.

  • Um único uber JAR que contém todos os arquivos de classe do plug-in e suas dependências.

Não agrupar suas dependências de plug-ins pode afetar a disponibilidade ou a compatibilidade no ambiente de execução e causar erros inesperados.

Para obter informações sobre como desenvolver o código para um conector, consulte o Guia de desenvolvimento de conectores na documentação do Apache Kafka.

Criando um plug-in personalizado usando o Console de gerenciamento da AWS

  1. Abra o console do Amazon MSK em https://console.aws.amazon.com/msk/.

  2. No painel esquerdo, em MSK Connect e escolha Plug-ins personalizados.

  3. Escolha Criar plug-in personalizado.

  4. Selecione Navegar no S3.

  5. Na lista de buckets do S3, escolha o bucket que contém o arquivo JAR ou ZIP do plug-in.

  6. Na lista de objetos, marque a caixa à esquerda do arquivo JAR ou ZIP do plug-in e clique em Escolher.

  7. Escolha Criar plug-in personalizado.

Para usar a API MSK Connect para criar um plug-in personalizado, consulte CreateCustomPlugin.