Para acceder a los datos con Apache Kafka, cree un activo de conexión para el mismo.
Apache Kafka es una plataforma de transmisión de sucesos distribuida. Conéctese a un servidor de proceso en tiempo real de Apache Kafka para escribir y leer secuencias de sucesos de y en temas.
Versiones soportadas
Apache Kafka versiones 0.11 - 2.x
Crear una conexión con Apache Kafka
Para crear el activo de conexión, necesita estos detalles de conexión.
Nombre de host del servidorKafka: Nombre de host y número de puerto del servidor Kafka . Utilice este formato: hostname:port-number. Para conectarse a un clúster Kafka , separe los valores con comas: hostname1:port-number1,hostname2:port-number2,hostname3:port-number3. Si se conecta a un clúster, la conexión utiliza todos los servidores independientemente de qué servidores se hayan especificado para la rutina de carga. Puesto que estos servidores se utilizan para la conexión inicial para descubrir la pertenencia completa al clúster, que puede cambiar dinámicamente, esta lista no necesita contener el conjunto completo de servidores. Pero si el clúster Kafka tiene tres hosts o menos, incluya todos los hosts en esta lista para evitar la pérdida de datos.
Conexión segura
Seleccione el protocolo de autenticación de red que está configurado en el servidor Kafka . Ninguno es el valor predeterminado. Estas son las otras selecciones y sus propiedades:
SASL OAUTHBEARER
Seleccione OAuth 2.0
- URL de servidor: URL de punto final de señal. Ejemplo:
https://example.com/oauth2/default/v1/token. - ID de cliente: el ID de cliente OAuth.
- Secreto de cliente: El secreto del cliente de OAuth
- Ámbito Ámbito opcional al que hacer referencia en la llamada al servidor OAuth.
- Propiedades adicionales: Opciones de configuración de OAuth adicionales. Especifique como pares
key=value. El valor de esta propiedad multilínea debe cumplir los requisitos de clase de propiedades Java. - Certificados de almacén de confianza: certificados de confianza en formato PEM. Sólo se da soporte a los certificados X.509.
SASL_Plain
Nombre de principal de usuario: El usuario autenticado en el servidor o clúster de Kafka .
Contraseña: Contraseña del nombre principal de usuario.
SASL_SSL
Nombre de principal de usuario: El usuario autenticado en el servidor o clúster de Kafka .
Contraseña: Contraseña del nombre principal de usuario.
Certificados de almacén de confianza: certificados de almacén de confianza en formato PEM. Sólo se da soporte a los certificados X.509.
SCRAM-SHA-256 o SCRAM-SHA-512
Nombre de principal de usuario: El usuario autenticado en el servidor o clúster de Kafka .
Contraseña: Contraseña del nombre principal de usuario.
Certificados de almacén de confianza: certificados de almacén de confianza en formato PEM. Sólo se da soporte a los certificados X.509.
SSL
Certificados de almacén de confianza: certificados de almacén de confianza en formato PEM. Sólo se da soporte a los certificados X.509.
Clave: clave privada en formato PEM. La clave debe utilizar la sintaxis PKCS #8 .
Cadena de certificados de claves: cadena de certificados para la clave privada en formato PEM. Sólo se da soporte a los certificados X.509.
Contraseña de clave: este valor es necesario si la clave está cifrada.
Formato de mensaje
Un registro de esquema es software de terceros que gestiona los mensajes y correlaciona los esquemas con temas para que los productores sepan qué temas aceptan qué tipos (esquemas) de mensajes y los consumidores sepan cómo leer y analizar los mensajes de un tema. Si selecciona Utilizar registro de esquema para formato de mensaje, puede seleccionar estos detalles adicionales para conectarse de forma segura al servicio de registro de esquema.
Requisito previo
Configure el registro de esquemas para su servidor Kafka con Confluent (se admiten las versiones 6.x y 7.x Confluent) o con IBM Event Streams.
URL de registro de esquema: URL al servicio de registro de esquema.
Autenticación
Seleccione el método de autenticación para el servicio de registro de esquema. Ninguno es el valor predeterminado. Estas son las otras selecciones y sus propiedades:
Utilice las credenciales de usuario SASL del servidor Kafka: Puede elegir esta selección si ha especificado propiedades para SASL_Plain o SASL_SSL para la conexión segura con el servidor Kafka . El nombre de usuario y la contraseña para los valores de seguridad de SASL se utilizarán para la autenticación en el servicio de registro de esquema.
Credenciales de usuario: Nombre de usuario y contraseña para el servicio de registro de esquema.
Conexión segura
Seleccione el protocolo de autenticación de red segura para el servicio de registro de esquemas. Ninguno es el valor predeterminado. Estas son las otras selecciones y sus propiedades:
Utilizar credenciales de usuario SSL del servidor Kafka: puede elegir esta selección si ha especificado propiedades para SSL para la conexión segura con el servidor Kafka . La configuración de certificados de la conexión del servidor Kafka se utilizará para la conexión segura con el servicio de registro de esquema.
SSL
- Certificados de almacén de confianza: certificados de almacén de confianza en formato PEM. Sólo se da soporte a los certificados X.509.
- Clave: clave privada en formato PEM. La clave debe utilizar la sintaxis PKCS #8 .
- Cadena de certificados de claves: cadena de certificados para la clave privada en formato PEM. Sólo se da soporte a los certificados X.509.
- Contraseña de clave: este valor es necesario si la clave está cifrada.
Tipo de registro de esquema
Seleccione el tipo de registro del esquema:
- Confluyente
- IBM Event Streams (API compatible con Confluent)
Elija el método para crear una conexión basada en el lugar en el que se encuentra en la plataforma
En un proyecto
Pulse Activos > Nuevo activo > Conectar a un origen de datos. Consulte Adición de una conexión a un proyecto.
En un catálogo
Pulse Añadir a catálogo > Conexión. Consulte Adición de un activo de conexión a un catálogo.
En el catálogo de activos de Platform assets catalog
Pulse Nueva conexión. Consulte Adición de conexiones de plataforma.
Paso siguiente: Añadir activos de datos desde la conexión
Dónde puede utilizar esta conexión
Puede utilizar la conexión de Apache Kafka en los siguientes espacios de trabajo y herramientas:
Proyectos
- Data Replication (servicio Data Replication). Puede duplicar datos de otras bases de datos en Apache Kafka utilizando Data Replication. Consulte Replicación de datos de Apache Kafka.
- DataStage (servicioDataStage ). Consulte Conexión a un origen de datos en DataStage.
Catálogos
Platform assets catalog
Otros catálogos (IBM Knowledge Catalog)
Nota:La vista previa, el perfil y el enmascaramiento no están certificados para esta conexión en IBM Knowledge Catalog.
Configuración de Apache Kafka
Más información
- Documentación de Kafka
- Descripción general del registro de esquemas de Confluent
- Uso del registro de esquemas de Event Streams
Tema principal: Conexiones soportadas