ApsaraMQ for Kafka:Créer un connecteur de réception Kafka

Prérequis

• Une instance ApsaraMQ for Kafka est déployée et son état est Running. Pour plus d'informations, consultez la page Acheter et déployer une instance.

• Activer EventBridge et accorder des autorisations.

Créer une tâche de connecteur de réception

1. Connectez-vous à la console ApsaraMQ for Kafka. Sur la page Overview, sélectionnez une région dans la section Resource Distribution.

2. Dans le volet de navigation de gauche, choisissez Connector Ecosystem Integration > Tasks.

3. Sur la page Tasks, cliquez sur Create Task.

4. Dans le panneau Create Task, définissez les champs Task Name et Description, configurez la tâche comme décrit ci-dessous, puis cliquez sur Save.

   • Création de la tâche

     1. À l'étape Source, sélectionnez Message Queue for Apache Kafka en tant que Data Provider. Configurez les paramètres suivants, puis cliquez sur Next.

        Parameter	Description	Example
        Région	Région de l'instance source Message Queue for Apache Kafka.	Chine (Pékin)
        Instance Kafka	Instance source Message Queue for Apache Kafka.	alikafka_post-cn-jte3****
        Topic	Topic source des messages.	demo-topic
        ID de groupe	Groupe de consommateurs de l'instance source. Quick Create (recommandé) : crée automatiquement un ID de groupe au format GID_EVENTBRIDGE_xxx. Use Existing : sélectionnez un ID de groupe existant. Ne partagez pas cet ID de groupe avec d'autres services afin d'éviter toute perturbation de la consommation des messages.	Quick Create
        Décalage du consommateur	Décalage de départ de la consommation des messages. Dernier décalage (latest) Premier décalage (earliest)	Dernier décalage (latest)
        Configuration réseau	Type de réseau pour le routage des messages. Basic Network Self-managed Internet	Basic Network
        VPC	Requis uniquement si le paramètre Configuration réseau est défini sur Self-managed Internet.	vpc-bp17fapfdj0dwzjkd****
        vSwitch	Requis uniquement si le paramètre Configuration réseau est défini sur Self-managed Internet.	vsw-bp1gbjhj53hdjdkg****
        Groupe de sécurité	Requis uniquement si le paramètre Configuration réseau est défini sur Self-managed Internet.	alikafka_pre-cn-7mz2****
        Data Format	Format d'encodage du contenu du message. Nous recommandons Json si vous n'avez pas d'exigences spécifiques en matière d'encodage. Json : encode les données binaires en objet JSON dans la charge utile à l'aide d'UTF-8. Text : encode les données binaires en chaîne UTF-8 dans la charge utile. Il s'agit du format par défaut. Binary : encode les données binaires en chaîne Base64 dans la charge utile.	Json
        Messages	Paramètre de configuration avancée. Nombre maximal de messages par lot. Une requête est envoyée lorsque le nombre cumulé de messages atteint cette valeur. Valeurs valides : 1 à 10 000.	100
        Interval (Unit: Seconds)	Paramètre de configuration avancée. Intervalle, en secondes, d'agrégation et d'envoi des messages à la destination. Valeurs valides : 0 à 15. Une valeur de 0 signifie que les messages sont livrés immédiatement.	3

     2. À l'étape Filtering, définissez le champ Pattern Content pour filtrer les événements. Pour plus d'informations, consultez la page modèle d'événement.

     3. À l'étape Transformation, configurez la transformation des données pour effectuer des opérations telles que le fractionnement, le mappage, l'enrichissement et le routage dynamique. Pour plus d'informations, consultez la page Utiliser Function Compute pour nettoyer les données des messages.

     4. À l'étape Sink, définissez le paramètre Service Type sur ApsaraMQ for Kafka et configurez les paramètres suivants.

        Parameter	Description	Example
        Instance ID	Sélectionnez l'instance de destination ApsaraMQ for Kafka.	test
        Topic	Sélectionnez un topic dans l'instance de destination.	test
        Acknowledgment Mode	Sélectionnez le signal d'accusé de réception que ApsaraMQ for Kafka envoie au client après réception des données. None LeaderOnly All	None
        Message Value	EventBridge utilise une expression JSONPath pour extraire un contenu spécifique d'un événement et le router vers la destination. Complete Data Data Extraction Fixed Value Template	Extraire de l'événement $.data.value
        Message Key	EventBridge utilise une expression JSONPath pour extraire un contenu spécifique d'un événement et le router vers la destination. Null Data Extraction Fixed Value Template	Extraire de l'événement $.data.key

   • Propriétés de la tâche

     Configurez la politique de nouvelle tentative et la file d'attente des messages morts pour cette tâche. Pour plus d'informations, consultez la page Nouvelles tentatives et files d'attente des messages morts.

5. Sur la page Tasks, localisez votre tâche et cliquez sur Enable dans la colonne Actions.

6. Dans la boîte de dialogue Note, lisez le message, puis cliquez sur OK.

   Le démarrage de la tâche prend entre 30 et 60 secondes après son activation. Vous pouvez consulter la progression du démarrage dans la colonne Status de la page Tasks.

Autres opérations

Sur la page Tasks, localisez la tâche cible et effectuez les opérations suivantes dans la colonne Actions.

• Afficher les détails de la tâche : cliquez sur Details. Sur la page Task, vous pouvez consulter les informations de base, les propriétés et les métriques de surveillance de la tâche.

• Modifier la configuration de la tâche : cliquez sur Edit. Dans le panneau Edit Task, vous pouvez modifier les détails et les propriétés de la tâche.

• Activer ou suspendre la tâche : cliquez sur Enable ou Pause. Dans la boîte de dialogue Note, cliquez sur OK.

• Supprimer la tâche : cliquez sur Delete. Dans la boîte de dialogue Note, cliquez sur OK.