Adición de un origen de Confluent Kafka a una secuencia de eventos (versión preliminar)

En este artículo se muestra cómo agregar un origen de Confluent Kafka a una secuencia de eventos.

Confluent Cloud Kafka es una plataforma de streaming que ofrece eficaces funcionalidades de procesamiento y streaming de datos mediante Apache Kafka. Al integrar Confluent Cloud Kafka como origen dentro de la secuencia de eventos, puede procesar sin problemas flujos de datos en tiempo real antes de enrutarlos a varios destinos dentro de Fabric.

Importante

Las funcionalidades mejoradas de flujos de eventos de Fabric se encuentran actualmente en versión preliminar.

Nota:

Este origen no se admite en las siguientes regiones de la capacidad de área de trabajo: Oeste de EE. UU. 3, Oeste de Suiza.

Requisitos previos

• Acceso a un área de trabajo Premium con los permisos Colaborador o superior.
• Un clúster de Confluent Cloud Kafka y una clave de API.
• El clúster de Confluent Cloud Kafka debe ser accesible públicamente y no estar detrás de un firewall o protegido en una red virtual.

Nota:

El número máximo de orígenes y destinos para una secuencia de eventos es 11.

Adición de Confluent Cloud Kafka como origen

1. Cree una secuencia de eventos con la selección del botón de alternancia de vista previa.
2. Seleccione Agregar origen externo.

Configuración y conexión a Confluent Kafka

1. En la página Seleccionar un origen de datos, seleccione Confluent.

   

2. Para crear una conexión al origen de Confluent Cloud Kafka, seleccione Nueva conexión.

   

3. En la sección Configuración de la conexión, escriba Confluent Bootstrap Server. Vaya a la página principal de Confluent Cloud, seleccione Configuración de clúster y copie la dirección en el servidor de arranque.

4. En la sección Credenciales de conexión, si tiene una conexión existente con el clúster de Confluent, selecciónela en la lista desplegable para Conexión. De lo contrario, siga estos pasos:

   1. Para Nombre de conexión, introduzca un nombre para la conexión.
   2. En Tipo de autenticación, confirme que Clave de Confluent Cloud esté seleccionado.
   3. Para Clave de API y Secreto de clave de API:

      1. Vaya a Confluent Cloud.

      2. Seleccione Claves de API en el menú lateral.

      3. Seleccione el botón Agregar clave para crear una nueva clave de API.

      4. Copie la Clave de API y el Secreto.

      5. Pegue esos valores en los campos Clave de API y Secreto de clave de API.

      6. Seleccione Conectar

         

5. Desplácese para ver la sección Configurar origen de datos de Confluent en la página. Escriba la información para completar la configuración del origen de datos de Confluent.

   1. En Tema, escriba un nombre de tema de Confluent Cloud. Puede crear o administrar el tema en Confluent Cloud Console.
   2. En Grupo de consumidores, escriba un grupo de consumidores de Confluent Cloud. Proporciona el grupo de consumidores dedicado para obtener los eventos del clúster de Confluent Cloud.
   3. En el ajuste Restablecer desplazamiento automático, seleccione uno de los siguientes valores:

      • Más antiguo: los datos más antiguos disponibles en el clúster de Confluent

      • Más reciente: los datos disponibles más recientes

      • Ninguno: no establecer automáticamente el desplazamiento.

        

6. Seleccione Siguiente. En la pantalla Revisar y crear, revise el resumen y, a continuación, seleccione Agregar.

Verá que el origen de Confluent Cloud Kafka se agrega a la secuencia de eventos en el lienzo en modo de edición. Para implementar este origen de Confluent Cloud Kafka recién agregado, seleccione Publicar en la cinta de opciones.

Después de completar estos pasos, el origen de Confluent Cloud Kafka está disponible para su visualización en la vista en vivo.

Contenido relacionado

Otros conectores:

• Flujos de datos de Amazon Kinesis
• Azure Cosmos DB
• Azure Event Hubs
• Azure IoT Hub
• Captura de datos modificados de la base de datos Azure SQL
• Punto de conexión personalizado
• Google Cloud Pub/Sub
• CDC de base de datos de MySQL
• CDC de base de datos de PostgreSQL
• Datos de ejemplo
• Eventos de Azure Blob Storage
• Evento de área de trabajo de Fabric