Posts

Showing posts with the label Apache Kafka

Intégrer Apache Kafka avec Java

 đź’ˇ Introduction Dans les applications d’entreprise modernes, la communication en temps rĂ©el entre les systèmes distribuĂ©s est devenue indispensable. Apache Kafka — une plateforme de streaming d’Ă©vĂ©nements distribuĂ©e — permet de crĂ©er des architectures orientĂ©es Ă©vĂ©nements, hautement performantes et tolĂ©rantes aux pannes. Dans ce guide, vous apprendrez Ă  intĂ©grer Kafka avec Spring Boot et le framework Spring classique , en crĂ©ant un producteur et un consommateur simples. ⚙️ 1️⃣ Qu’est-ce qu’Apache Kafka ? Apache Kafka est une plateforme de streaming d’Ă©vĂ©nements distribuĂ©e conçue pour : Publier et souscrire des flux de donnĂ©es Traiter des Ă©vĂ©nements en temps rĂ©el Connecter des systèmes via des files de messages fiables Kafka est souvent utilisĂ© pour : La communication entre microservices La centralisation des journaux L’analyse temps rĂ©el Les dĂ©clencheurs de processus BPM (comme jBPM) đź§© 2️⃣ Concepts de base Composant Description Producer (...

Integrate Kafka with Java

 đź’ˇ Introduction In modern enterprise applications, real-time communication between distributed systems is crucial. Apache Kafka — the powerful distributed streaming platform — enables high-throughput, fault-tolerant event-driven architectures. In this blog, we’ll see how to integrate Kafka with both Spring Boot and classic Spring Framework , using practical examples for Producer and Consumer applications. ⚙️ 1️⃣ What Is Apache Kafka? Apache Kafka is a distributed event streaming platform designed for: Publishing and subscribing to data streams Processing real-time data Connecting systems using reliable message queues Kafka is often used for: Microservice communication Log aggregation Real-time analytics BPM and workflow triggers (like jBPM event integration) đź§© 2️⃣ Core Concepts Component Description Producer Sends (publishes) messages to Kafka topics Consumer Reads messages from Kafka topics Topic A category or feed name to which messages ...

IntĂ©grer jBPM avec un serveur Apache Kafka – Guide complet

 đź’ˇ Introduction Dans les architectures modernes orientĂ©es Ă©vĂ©nements, l’intĂ©gration de ⚙️ jBPM (Business Process Management) avec 📡 Apache Kafka permet d’obtenir une visibilitĂ© et une automatisation en temps rĂ©el entre diffĂ©rents systèmes. jBPM peut envoyer automatiquement ses Ă©vĂ©nements de processus, mises Ă  jour de tâches et journaux vers un serveur Kafka (broker) — facilitant l’analyse, l’audit et la communication entre microservices. Ce guide explique comment connecter jBPM Ă  un serveur Kafka sans aucun code Java , uniquement avec des paramètres dans WildFly / KIE Server . ⚙️ 1️⃣ PrĂ©requis Avant de commencer, assurez-vous d’avoir : ✅ Un serveur Kafka (Broker) en cours d’exĂ©cution (ex. : localhost:9092 ou votre IP/port distant) ✅ jBPM / KIE Server dĂ©ployĂ© sur WildFly ✅ L’accès pour modifier standalone.xml ou standalone.conf Si vous utilisez un Kafka hĂ©bergĂ© dans le cloud (comme Azure Event Hubs ou Confluent Cloud ), notez les paramètres de connexion (hĂ´te, ...

Integrate jBPM with Apache Kafka Server – Complete Setup Guide

 đź’ˇ Introduction In modern event-driven architectures, integrating ⚙️ jBPM (Business Process Management) with 📡 Apache Kafka unlocks real-time visibility and automation across systems. jBPM can publish its process events, task updates, and logs directly to a Kafka server (broker) — enabling analytics, auditing, and microservice event chaining. This guide shows you how to connect jBPM to a running Kafka Server without writing any Java code , using only configuration changes in WildFly / KIE Server . ⚙️ 1️⃣ Prerequisites Before starting, make sure you have: ✅ Kafka Server (Broker) up and running (e.g., localhost:9092 or your remote broker IP/port) ✅ jBPM / KIE Server deployed on WildFly ✅ Access to modify standalone.xml or standalone.conf If you’re using a cloud Kafka (like Azure Event Hubs or Confluent Cloud), note the connection parameters (host, port, protocol, username, password or connection string). đź§  2️⃣ Enable jBPM Kafka Event Emitter jBPM includes a r...