Cómo solucionar problemas relacionados con un tema de importación de Amazon Managed Streaming para Apache Kafka

En este documento, se proporcionan algunas sugerencias habituales para solucionar problemas relacionados con los temas de importación de Amazon Managed Streaming for Apache Kafka (Amazon MSK).

Después de configurar el tema de importación y comenzar a transferir mensajes, puedes verificar las métricas pertinentes de Cloud Monitoring para ver si se transfirieron los datos. Sigue los siguientes pasos:

  1. En la consola, ve a la página Temas.

    Ir a temas

  2. Haz clic en el tema de importación de Amazon MSK que deseas solucionar.

  3. En la página de detalles del tema, haz clic en la pestaña Métricas.

  4. Consulta el gráfico de la métrica Ingestion byte count.

  5. Si no se ingieren datos, en la página de detalles del tema, verifica si hay un error en el campo Estado del tema.

  6. También puedes consultar la métrica Estado de la fuente de datos de la transferencia. Para ello, en la página de detalles del tema, haz clic en la pestaña Métricas.

  7. A continuación, se incluye una lista de errores que puedes encontrar:

    Código de error Descripción Corregir
    MSK_PERMISSION_DENIED Se produjo un error al consumir datos de Amazon MSK debido a problemas de permisos. Verifica que el ARN del rol de AWS sea preciso y comprueba que el rol de AWS tenga los permisos de lectura necesarios. Para obtener más información, consulta Crea una política en AWS.
    Asegúrate de que exista una cuenta de servicio y de que esté configurada correctamente, como se describe en el procedimiento Crea un rol en AWS con una política de confianza personalizada. Para obtener más información sobre cómo crear una cuenta de servicio, consulta Crea una cuenta de servicio en Google Cloud.
    Verifica que la cuenta de servicio de Pub/Sub tenga el permiso iam.serviceAccounts.getOpenIdToken. Para obtener más información, consulta Cómo agregar el rol de creador de tokens de cuenta de servicio a la cuenta de servicio de Pub/Sub.
    Verifica que hayas agregado el rol de usuario de cuenta de servicio a la cuenta de servicio. Para obtener más información, consulta Cómo agregar el rol de usuario de cuenta de servicio a la cuenta de servicio.
    PUBLISH_PERMISSION_DENIED Se produjo un error al publicar en el tema de Pub/Sub debido a problemas de permisos. Otorga a la cuenta de servicio de Pub/Sub los permisos de publicación necesarios. Para obtener más información, consulta Cómo agregar el rol de publicador de Pub/Sub a la cuenta de servicio de Pub/Sub.
    CLUSTER_NOT_FOUND No se encontró el clúster proporcionado. Verifica que el ARN del clúster sea correcto. Asegúrate de que el clúster exista y sea accesible.
    Cluster is not public No se puede acceder al clúster proporcionado No se admiten los clústeres no públicos detrás de las VPC. Debes usar un clúster público.
    TOPIC_NOT_FOUND No se encontró el tema de Kafka proporcionado. Verifica que el nombre del tema sea correcto. Asegúrate de que el tema exista en el clúster especificado.

Si no hay errores hasta este punto, consulta las prácticas recomendadas en Mantén un publicador en buen estado.

También puedes habilitar los registros de la plataforma para un tema de importación. Estos registros te ayudan a solucionar problemas cuando tienes dificultades para transferir objetos a los temas de importación de Pub/Sub.

Apache Kafka® es una marca registrada de The Apache Software Foundation o sus afiliados en Estados Unidos y otros países.