Event Driven Microservices Based Distributed Data Intelligence for Real Time High Throughput Enterprise Applications
Keywords:
Event-Driven Architecture, Microservices, Distributed Data Intelligence, Real-Time Processing, High Throughput, Stream Processing, Enterprise Applications, Apache KafkaAbstract
Modern enterprise applications demand real-time data intelligence to process massive, continuous streams of information with sub-second latency. Traditional monolithic architectures and request-response paradigms often introduce bottlenecks, failing to meet the scalability and throughput requirements of contemporary digital business. This paper proposes an architectural framework that integrates Event-Driven Microservices (EDM) with distributed data intelligence pipelines to address these challenges. By leveraging asynchronous communication, persistent event logs (e.g., Apache Kafka), and stream processing engines (e.g., Apache Flink), the framework enables decoupled, resilient, and highly responsive services. We demonstrate how embedding intelligence—such as pattern detection, anomaly scoring, and predictive analytics—directly within the event streaming layer facilitates high-throughput processing. A case study in financial fraud detection illustrates the architecture’s effectiveness in achieving sub-50ms latency for over 1 million events per second. The paper concludes with performance benchmarks and a discussion on trade-offs between consistency, fault tolerance, and event ordering.
References
1) Eugster, P. Th., Felber, P. A., Guerraoui, R., & Kermarrec, A. M. (2003). The many faces of publish/subscribe. ACM CSUR, 35(2), 114-131.
2) Wadhwa, R. (2025). A service-oriented data architecture for enterprise systems using event-driven microservices and distributed storage. IACSE – International Journal of Scientific Computing, 6(2), 7–19. https://doi.org/10.5281/zenodo.19734323
3) Vogels, W. (2009). Eventually consistent. Communications of the ACM, 52(1), 40-44.
4) Newman, S. (2015). Building Microservices. O’Reilly Media.
5) Kleppmann, M. (2017). Designing Data-Intensive Applications. O’Reilly.
6) Kreps, J., Narkhede, N., & Rao, J. (2011). Kafka: a distributed messaging system for log processing. NetDB Workshop.
7) Carbone, P., Katsifodimos, A., Ewen, S., Markl, V., Haridi, S., & Tzoumas, K. (2015). Apache Flink: Stream and batch processing in a single engine. IEEE Data Eng. Bull., 38(4), 28-38.
8) Wadhwa, R. (2025). Engineering autonomous enterprise systems using event-driven microservices and distributed data intelligence. Frontiers in Computer Science and Information Technology, 6(4), 66–79. https://doi.org/10.34218/FCSIT_06_04_002
9) Akidau, T., Bradshaw, R., Chambers, C., Chernyak, S., Fernández-Moctezuma, R. J., Lax, R., ... & Whittle, S. (2015). The dataflow model: a practical approach to balancing correctness, latency, and cost in massive-scale, unbounded, out-of-order data processing. Proceedings of the VLDB Endowment, 8(12), 1792-1803.
10) Bonér, J. (2017). Reactive Microservices Architecture. O’Reilly Media.
11) Wadhwa, R. (2025). A DevOps-oriented approach to enterprise systems engineering with event-driven microservices and distributed data systems. International Journal of Microservices and Applications, 3(1), 22–34. https://doi.org/10.34218/IJMA_03_01_003
12) Van der Merwe, J., Ramakrishna, V., & Dube, P. (2017). Performance analysis of RESTful and event-driven microservices. IEEE IC2E, 231-237.
13) Hesse, G., & Wirtz, G. (2018). Saga composition in event-driven microservices. Symposium on Applied Computing, 1246-1253.
14) Sumbaly, R., Kreps, J., & Shah, A. (2013). The big data ecosystem at LinkedIn. ACM SIGMOD, 1129-1134.
15) Carbone, P., Ewen, S., Fóra, G., Haridi, S., Richter, S., & Tzoumas, K. (2017). State management in Apache Flink. VLDB Journal, 26(3), 399-424.
16) Zaharia, M., Das, T., Li, H., Hunter, T., Shenker, S., & Stoica, I. (2016). Apache Spark Streaming. Communications of the ACM, 59(6), 86-93.
17) Armbrust, M., Das, T., Sun, L., Yavuz, B., Zhu, S., Murthy, M., ... & Zaharia, M. (2021). Delta Lake: high-performance ACID table storage over cloud object stores. Proceedings of the VLDB Endowment, 13(12), 3411-3424.
18) Akidau, T., Chernyak, S., & Lax, R. (2021). Streaming Systems. O’Reilly Media.
Downloads
Published
Issue
Section
Deprecated: urlencode(): Passing null to parameter #1 ($string) of type string is deprecated in /home/u877385332/domains/ijraics.com/public_html/plugins/generic/pflPlugin/PflPlugin.php on line 216



