Depuis la version 7.6.1.2, Maximo prend en charge Apache Kafka en tant que fournisseur de messages, remplaçant les files d’attente JMS traditionnelles. Cette intégration offre la possibilité de gérer les flux de messages en utilisant Kafka pour l’entrée et la sortie des sujets, ainsi que pour les files d’attente continues.
Configuration de Kafka pour Maximo
Maximo ne fournit pas de courtier Kafka intégré ; il est donc nécessaire de configurer un courtier Kafka externe. Vous pouvez opter pour un service géré comme AWS, Azure, ou IBM Cloud, ou bien configurer un courtier sur site. L’adoption de Kafka présente plusieurs avantages, tels qu’une évolutivité améliorée, une configuration simplifiée par rapport à Java EE complexe (comme web.xml), et une large gamme d’outils de support open-source. Cette méthode est particulièrement pertinente pour Maximo Manage, qui sera inclus dans la Maximo Application Suite (MAS) et intégrera Kafka Operator par défaut.
Illustration de l’architecture Kafka
Pour plus de détails sur la configuration avec Maximo Application Suite, consultez le guide d’administration de MAS.
Fonctionnement des files d’attente avec Apache Kafka
Pour une gestion efficace des files d’attente avec Kafka, il est essentiel de comprendre son architecture. Kafka sépare les processus d’entrée et de sortie : les producteurs gèrent l’entrée, tandis que les consommateurs s’occupent de la sortie. Les courtiers Kafka sont responsables de la gestion des partitions de sujets. La mise à l’échelle de Kafka est réalisée en créant plusieurs partitions, chaque partition étant gérée par un courtier spécifique. Les producteurs obtiennent les informations de partition du courtier pour acheminer les messages, tandis que chaque consommateur traite une partition assignée. Pour une performance optimale, il est crucial de préparer un nombre suffisant de partitions et de consommateurs.
Configuration des files d’attente Kafka dans Maximo
La configuration de Kafka dans Maximo est similaire à celle de JMS, mais utilise les mécanismes spécifiques de Kafka au lieu des configurations Java EE. Lors de l’utilisation de Maximo Integration Framework (MIF), les utilisateurs peuvent choisir entre Kafka et JMS sans avoir à se soucier des détails techniques.
Pour configurer Kafka :
- Ajout de Kafka comme fournisseur de messages : Accédez à « Système externe » et ajoutez Kafka en tant que fournisseur de messages en configurant les paramètres de sécurité en fonction du service ou de la configuration utilisée.
- Enregistrement de la file d’attente : Configurez la file d’attente via « Ajouter/Modifier une file d’attente » dans « Système externe ». Si vous ne pouvez pas sélectionner une file d’attente, vérifiez la connexion à Kafka et l’enregistrement de la file d’attente. (Pour plus de détails, y compris les périodes de conservation, référez-vous au Centre de connaissances IBM).
- Configuration des tâches périodiques : Sélectionnez Kafka dans la configuration des tâches cron et ajoutez une instance pour les files d’attente continues. Indiquez le nom du fournisseur dans la propriété MESSAGEHUB et le sujet Kafka de la file d’attente continue (par exemple, cqin). Ajoutez davantage d’instances en fonction du nombre de partitions.
- Envoi de messages : Vous pouvez envoyer des messages vers une file d’attente via le système externe ou directement depuis le client Kafka.
- Pour plus de détails, consultez le guide sur le traitement des messages Kafka et le guide de traitement Kafka dans Maximo.
Équilibrage des partitions avec les services d’entreprise
Après configuration, vous pourriez observer un déséquilibre dans la répartition des messages entre les partitions. Maximo attribue par défaut une « clé » aux messages envoyés à Kafka, déterminant la partition cible via un hachage de la clé. Pour un équilibrage plus homogène, vous pouvez activer l’option mxe.int.kafkausenullkey, qui évite la définition de clés spécifiques et permet une répartition plus uniforme des messages entre les partitions. Notez que ce paramètre n’est pas toujours documenté, donc utilisez-le avec prudence.
Pour résumé, configurer Kafka comme fournisseur de messages dans Maximo est un moyen puissant de gérer vos files d’attente et flux de messages. Avec l’importance croissante de Kafka dans les futures versions de Maximo, il est judicieux de se familiariser avec cette technologie dès maintenant pour préparer votre système à l’évolution des besoins.
