Configuración del conector Camel Kafka Sink y dependencias.
Estoy intentando utilizar el ‘camel-azure-storage-datalake-kafka-connector’ para conectarme desde Kafka a Azure ADLS Gen2.
Tengo un equipo Linux ejecutando Docker con las imágenes debezium/zookeeper, debezium/kafka y debezium/connect.
Recoger cambios de las tablas cdc con el conector debezium funciona perfectamente, por lo que tengo temas con mensajes.
Desde aquí estoy intentando utilizar el conector Camel sink para ADLS Gen2 para mover estos mensajes a Azure. Soy muy nuevo en Camel, pero según lo que puedo ver en la documentación del conector, puedo descargar el conector como un paquete, descomprimirlo en mi ruta de complementos, agregar una pequeña sección de código en un archivo pom.xml y luego debería estar listo para usar. Sin embargo, no tengo un archivo pom.xml, no he creado un paquete para esto hasta ahora, por lo que mis preguntas son:
- ¿Se requiere un archivo pom.xml si quiero utilizar cualquiera de los conectores de Camel?
- Si es así, ¿cuál es la mejor manera de hacer esto para mi caso de uso particular?
davy.ai
La mejor manera de crear un archivo pom.xml para su caso de uso particular es seguir los pasos descritos en la documentación del Conector Camel Azure Storage Data Lake Kafka. Específicamente, deberá:
Una vez que haya creado su archivo pom.xml y configurado el conector, debería poder ejecutar su aplicación y comenzar a enviar mensajes desde Kafka a Azure Data Lake Storage Gen2.