Crear un origen de datos de Kafka - ApsaraDB for OceanBase (Deprecated)

Debe configurar los orígenes de datos antes de crear una tarea de migración o sincronización de datos. Este tema describe cómo crear un origen de datos de Kafka mediante el servicio de transmisión de datos.

Riesgos de seguridad

Puede elegir agregar bloques CIDR públicos para el servicio de transmisión de datos de forma automática o manual, pero existen riesgos de seguridad. El uso del servicio de transmisión de datos indica que ha comprendido y aceptado los posibles riesgos de seguridad. Debe tomar medidas básicas de protección, como establecer una contraseña compleja para su cuenta, limitar los números de puerto abiertos de los bloques CIDR, habilitar la autenticación para la comunicación entre API internas y revisar periódicamente los bloques CIDR para eliminar aquellos que no sean necesarios.

El servicio de transmisión de datos agregará o eliminará los bloques CIDR añadidos automáticamente a una lista de permitidos o security group según las necesidades del negocio y los riesgos de seguridad. No utilice los bloques CIDR de una lista de permitidos o security group para fines distintos al servicio de transmisión de datos. Si utiliza dichos bloques CIDR para otras necesidades empresariales, los problemas derivados quedarán fuera del alcance de la garantía del SLA del servicio de transmisión de datos. Para obtener más información sobre cómo agregar una dirección IP a una lista de permitidos o security group para el servicio de transmisión de datos, consulte Add a whitelist.

Limitaciones

El servicio de transmisión de datos permite agregar una instancia de Kafka únicamente como destino para la sincronización de datos.

Contexto

La seguridad de los datos es una preocupación principal durante la verificación de conectividad del servicio, la creación de vínculos y la transmisión de datos. Con base en el sistema de seguridad proporcionado por el servicio de Kafka, la transmisión de datos puede cumplir con la mayoría de los requisitos de seguridad en cifrado de datos y autenticación de usuarios.

La transmisión de datos admite los siguientes métodos de autenticación de Kafka:

GSSAPI

Generic Security Services Application Program Interface (GSSAPI) es un framework que proporciona servicios de seguridad genéricos. Admite el protocolo Kerberos.
PLAIN

La autenticación PLAIN es sencilla y no admite cambios dinámicos de usuarios. En este modo de autenticación, los nombres de usuario y las contraseñas se configuran en texto sin formato, lo que resulta en una baja seguridad.
SCRAM-SHA-256

Salted Challenge Response Authentication Mechanism (SCRAM) autentica a los usuarios mediante nombre de usuario y contraseña. SCRAM-SHA-256 puede utilizarse junto con Transport Layer Security (TLS) para la autenticación de seguridad.

En este método de autenticación, los usuarios pueden modificarse dinámicamente y los datos de usuario se almacenan en ZooKeeper. Antes de iniciar un broker, debe crearse un usuario para la comunicación entre el broker y ZooKeeper. Sin embargo, en este método de autenticación los nombres de usuario y las contraseñas se configuran en texto sin formato.
SCRAM-SHA-512

SCRAM-SHA-512 puede utilizarse junto con TLS para la autenticación de seguridad.

Procedimiento

Inicie sesión en ApsaraDB for OceanBase console

.
En el panel de navegación izquierdo, seleccione Data Transmission > Data Source Management.
En la página Data Sources, haga clic en New Data Source en la esquina superior derecha.
En el cuadro de diálogo New Data Source, seleccione Kafka en Data Source Type.

Seleccione un valor para Instance Type y configure los parámetros.

Si selecciona Alibaba Cloud Kafka Instance, configure los siguientes parámetros.

Parámetro	Descripción
Data Source Identifier	Se recomienda establecer una combinación de dígitos y letras. No debe contener espacios ni exceder los 32 caracteres de longitud.
Cross Alibaba Cloud Account	El servicio de transmisión de datos permite configurar una tarea para migrar o sincronizar datos entre instancias de diferentes cuentas de Alibaba Cloud. Puede elegir si desea seleccionar esta opción según sus necesidades empresariales. Si la selecciona, introduzca la cuenta de Alibaba Cloud de la instancia de destino. Si no tiene permisos sobre dicha cuenta, solicite primero la autorización. Para obtener más información, consulte Apply for cross-account authorization.
Kafka Instance ID	El ID único de la instancia de Kafka que solicitó.
Access Point	La lista de direcciones IP y puertos del servidor de Kafka. El sistema importa esta lista automáticamente. Nota Al especificar un punto de acceso de Kafka, no puede introducir un nombre de dominio. Solo se admite una dirección IP. Si es obligatorio usar un nombre de dominio, debe configurarlo en `advertised.listener` de la instancia de Kafka.
Username	El nombre de usuario de inicio de sesión de la instancia de Kafka.
Password	La contraseña de inicio de sesión de la instancia de Kafka.
Remarks (Optional)	Información adicional sobre el origen de datos.

Si selecciona Create Kafka Instance in VPC o Public Network Kafka Instance, configure los siguientes parámetros.

Parámetro	Descripción
Data Source Identifier	Se recomienda establecer una combinación de dígitos y letras. No debe contener espacios ni exceder los 32 caracteres de longitud.
Cross Alibaba Cloud Account	El servicio de transmisión de datos permite configurar una tarea para migrar o sincronizar datos entre instancias de diferentes cuentas de Alibaba Cloud. Puede elegir si desea seleccionar esta opción según sus necesidades empresariales. Si la selecciona, introduzca la cuenta de Alibaba Cloud de la instancia de destino. Si no tiene permisos sobre dicha cuenta, solicite primero la autorización. Para obtener más información, consulte Apply for cross-account authorization. Importante Este parámetro no se muestra cuando se selecciona Kafka Instance in Public Network como tipo de instancia.
VPC	Seleccione el ID único de una VPC que haya solicitado en la lista desplegable, o introduzca un nombre de VPC para realizar una búsqueda aproximada. Importante Este parámetro solo se muestra cuando establece el tipo de instancia en Create Kafka Instance in VPC.
Deployment in VPC/Cross-ISP Deployment	En el despliegue entre ISP, los orígenes y destinos de datos se encuentran en redes diferentes, incluidas distintas VPC o proveedores de servicios en la nube. Elija Deployment in VPC o Cross-ISP Deployment según sus necesidades empresariales. Seleccione todos los vSwitch a los que pertenecen todas las instancias de bootstrap server y `broker server` del servicio de Kafka en la lista de `vSwitches`. Agregue los bloques CIDR del vSwitch a la lista de permitidos del security group de la VPC actual. Un vSwitch es un módulo de red básico de una VPC y se utiliza para conectar instancias de recursos en la nube. Para obtener más información, consulte Overview. Importante Si el tipo de instancia se establece en Self-Managed Kafka Instance in VPC, puede seleccionar el modo de despliegue y los vSwitch. En el caso de despliegue entre ISP, las direcciones de enrutamiento estático (direcciones o bloques CIDR en VPC de otras nubes o IDC locales) se asocian automáticamente con el primer vSwitch seleccionado.
Access Point	La lista de direcciones IP y puertos del servidor de Kafka.
Enable SSL	Elija si desea habilitar Secure Sockets Layer (SSL) según las necesidades del negocio. Para habilitar SSL, haga clic en Upload File y cargue un certificado SSL con sufijo `.jks`.
Enable Authentication	Elija si desea habilitar la autenticación según las necesidades del negocio. Kafka proporciona cifrado de datos y varios mecanismos de autenticación de identidad para garantizar la seguridad de los datos y servicios del usuario.
Authentication Method	Si la autenticación está habilitada, debe especificar el método de autenticación. La transmisión de datos admite los siguientes métodos: GSS-API, PLAIN, SCRAM-SHA-256 y SCRAM-SHA-512.
KDC Server Address	La dirección IP o nombre de dominio del servidor Kerberos Key Distribution Center (KDC). Nota: Este parámetro solo se muestra cuando establece Authentication Method en GSSAPI.
User Entity	Introduzca el nombre de usuario. Nota: Este parámetro solo se muestra cuando establece Authentication Method en GSSAPI.
Keytab File	Haga clic en Upload File y cargue un archivo de clave con sufijo `.keytab`. Nota: Este parámetro solo se muestra cuando establece Authentication Method en GSSAPI.
Username	El nombre de usuario de la cuenta utilizada para la migración o sincronización de datos. Nota: Este parámetro no se muestra cuando establece Authentication Method en GSSAPI.
Password	La contraseña de la cuenta utilizada para la migración o sincronización de datos. Nota: Este parámetro no se muestra cuando establece Authentication Method en GSSAPI.
Remarks (Optional)	Información adicional sobre el origen de datos.

Haga clic en Test Connection para verificar la conexión de red entre el servicio de transmisión de datos y el origen de datos, así como la validez del nombre de usuario y la contraseña.
Una vez superada la prueba, haga clic en OK.