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 section 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
        Region	Région de l'instance Message Queue for Apache Kafka source.	China (Beijing)
        Kafka instance	Instance Message Queue for Apache Kafka source.	alikafka_post-cn-jte3****
        Topic	Topic source des messages.	demo-topic
        Group ID	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
        Consumer offset	Offset de départ de la consommation des messages. Latest offset (latest) Earliest offset (earliest)	Latest offset (latest)
        Network configuration	Type de réseau pour le routage des messages. Basic Network Self-managed Internet	Basic Network
        VPC	Requis uniquement si le paramètre Network configuration est défini sur Self-managed Internet.	vpc-bp17fapfdj0dwzjkd****
        vSwitch	Requis uniquement si le paramètre Network configuration est défini sur Self-managed Internet.	vsw-bp1gbjhj53hdjdkg****
        Security group	Requis uniquement si le paramètre Network configuration est défini sur Self-managed Internet.	alikafka_pre-cn-7mz2****
        Data Format	Format d'encodage du contenu du message. Nous vous recommandons d'utiliser Json si vous n'avez pas d'exigences spécifiques en matière d'encodage. Json : encode les données binaires sous forme d'objet JSON dans la charge utile à l'aide de UTF-8. Text : encode les données binaires sous forme de chaîne UTF-8 dans la charge utile. Il s'agit du format par défaut. Binary : encode les données binaires sous forme de chaîne encodée en Base64 dans la charge utile.	Json
        Messages	Paramètre de Advanced configuration. 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 Advanced configuration. Intervalle, en secondes, auquel les messages sont agrégés et envoyés à 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 section 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 section 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 ApsaraMQ for Kafka de destination.	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 la 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	Extract from Event $.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	Extract from Event $.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 section 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 afficher 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.