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 comunes 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 ingerir mensajes, puedes consultar las métricas pertinentes de Cloud Monitoring para ver si se ingieren 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 Topic state.

  6. También puedes consultar la métrica Ingestion data source state. Para ello, en la página de detalles del tema, haz clic en la pestaña Métricas.

  7. A continuación, se muestra una lista de los errores que podrías encontrar:

    Código de error Descripción Corregir
    MSK_PERMISSION_DENIED Error al consumir datos de Amazon MSK debido a problemas de permisos. Verifica que el ARN del rol de AWS sea correcto y 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 iam.serviceAccounts.getOpenIdToken permiso. Para obtener más información, consulta Agrega el rol de creador de tokens de cuenta de servicio a la cuenta de servicio de Pub/Sub service account.
    Verifica que hayas agregado el rol de usuario de cuenta de servicio a la cuenta de servicio. Para obtener más información, consulta Agrega el rol de usuario de cuenta de servicio a la cuenta de servicio.
    PUBLISH_PERMISSION_DENIED 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 permisos. Para obtener más información, consulta Agrega 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 clústeres no públicos detrás de 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 dentro del 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 problemas para ingerir objetos en 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.