Creación de complementos personalizados - Transmisión administrada de Amazon para Apache Kafka

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Creación de complementos personalizados

Un complemento es un AWS recurso que contiene el código que define la lógica del conector. Debe cargar un archivo JAR (o un archivo ZIP que contenga uno o más archivos JAR) en un bucket de S3 y especificar la ubicación del bucket al crear el complemento. Cuando se crea el complemento, MSK Connect copia el contenido del objeto S3 en ese momento. No mantiene un enlace al objeto S3, por lo que cualquier modificación posterior del objeto no afectará al complemento ni a sus conectores. Al crear un conector, debe especificar el complemento que desea que MSK Connect utilice para este. La relación entre los complementos y los conectores es la one-to-many siguiente: puede crear uno o más conectores a partir del mismo complemento.

nota

Los complementos personalizados no se pueden actualizar in situ. Para usar una nueva versión del código del complemento, elimine todos los conectores que hagan referencia al complemento, elimine el complemento y, a continuación, vuelva a crearlo.

Paquete de dependencias para complementos personalizados

Te recomendamos que incluyas todos los archivos JAR y las dependencias necesarios para tu complemento. Package el conector como uno de los siguientes:

  • Un archivo ZIP que contiene todos los archivos JAR y las dependencias necesarios para el complemento.

  • Un único uber JAR que contiene todos los archivos de clases del complemento y sus dependencias.

No agrupar las dependencias del plugin puede afectar a la disponibilidad o la compatibilidad en el entorno de ejecución y provocar errores inesperados.

Para obtener información sobre cómo desarrollar el código de un conector, consulte la Guía de desarrollo de conectores en la documentación de Apache Kafka.

Crear un complemento personalizado mediante el Consola de administración de AWS
  1. Abra la consola de Amazon MSK en https://console.aws.amazon.com/msk/.

  2. En el panel izquierdo, en MSK Connect, seleccione Complementos personalizados.

  3. Seleccione Crear complemento personalizado.

  4. Elija Examinar S3.

  5. En la lista de buckets de S3, elija el bucket que contenga el archivo JAR o ZIP del complemento.

  6. En la lista de objetos, seleccione la casilla situada a la izquierda del archivo JAR o ZIP del complemento y, a continuación, seleccione Elegir.

  7. Seleccione Crear complemento personalizado.

Para usar la API MSK Connect para crear un complemento personalizado, consulte CreateCustomPlugin.