Conector Apache Kafka en Jitterbit Studio

Resumen

El conector Apache Kafka establece acceso a Apache Kafka.

El conector Apache Kafka proporciona una interfaz para crear una conexión Apache Kafka, la base utilizada para generar instancias de actividades Apache Kafka. Estas actividades, una vez configuradas, interactúan con Apache Kafka a través de la conexión.

Se accede al conector Apache Kafka desde la pestaña Project endpoints and connectors de la paleta de componentes de diseño (consulta Design component palette).

Descripción general del conector

Este conector se utiliza para configurar primero una conexión Apache Kafka. Los tipos de actividad asociados con esa conexión se utilizan luego para crear instancias de actividades que se pretende usar como orígenes (para proporcionar datos en una operación) o destinos (para consumir datos en una operación).

En conjunto, una conexión Apache Kafka específica y sus actividades se denominan punto de conexión Apache Kafka:

• Send Message: Envía flujos de datos a un tema en un clúster Apache Kafka y se pretende usar como destino en una operación.

• Get Messages: Recupera flujos de datos de un tema en un clúster Apache Kafka y se pretende usar como origen en una operación.

Los puntos de conexión creados con este conector se incluyen en endpoint usage reporting y cuentan para tu licencia.

Requisitos previos y versiones de API compatibles

Este conector se puede usar con agentes en la nube y agentes privados.

Los agentes descargan automáticamente la versión más reciente de este conector cuando es necesario. En agentes privados, puedes suspender estas actualizaciones con la política de organización Disable Auto Connector Update.

El conector Apache Kafka utiliza la Apache Kafka Core API. Consulta la documentación de la API para obtener información sobre los nodos de esquema y los campos.

Solución de problemas

Si experimentas problemas con el conector Apache Kafka, se recomiendan estos pasos para la solución de problemas:

1. Haz clic en el botón Test en la configuración de conexión para asegurar que la conexión sea exitosa y para asegurar que la versión más reciente del conector se descargue en el agente (a menos que uses la política de organización Disable Auto Connector Update).

2. Revisa los registros de operación para obtener cualquier información escrita durante la ejecución de la operación.

3. Habilita el registro de depuración de operación (para agentes en la nube o para agentes privados) para generar archivos de registro y datos adicionales.

4. Si usas agentes privados, puedes habilitar registro detallado del conector para este conector agregando esta entrada de configuración de registrador al archivo logback.xml de tu agente privado:

   <logger name="org.jitterbit.connector.apache.kafka" level="DEBUG"/>
   

   Para obtener más información sobre el registro detallado del conector, consulta Verbose logging for connectors using Jitterbit private agents.

5. Si usas agentes privados, puedes revisar los registros del agente para obtener más información.

6. Para consideraciones adicionales de solución de problemas, consulta Solución de problemas de operaciones.