Scalable Software Engineering Architecture for AI-Enabled ETL Pipelines Using Event-Driven Microservices
Article Information
Abstract
As data ecosystems become more diverse and time-critical, traditional monolithic ETL pipelines face challenges to meet the demands of modern data engineering workloads in terms of scalability, adaptability, and operational resilience. In this paper, we introduce an event-driven microservices approach to orchestrate and deploy AI-based ETL (ETL = Extraction, Transformation, and Loading) pipelines in a Kubernetes-managed environment that includes the following components: asynchronous orchestration using Apache Kafka, hybrid anomaly detection, adaptive schema inference, and predictive load balancing. The proposed architecture breaks the ETL processing into loosely coupled services, which can be deployed and scaled independently, and incorporates data quality intelligence into the transformation layer. Two explicit baselines are used for experimental evaluation: (1) a traditional monolithic batch-processing ETL pipeline with sequential execution of the stages performed without horizontal scaling, and (2) an event-driven microservices pipeline, which uses Apache Kafka orchestration but no AI-enabled optimization modules. The framework is able to achieve 39.7% improvement in throughput (4,820 vs. 3,450 records/sec) and 96.3% anomaly detection accuracy, while reducing average E2E latency by 14.6% (245 vs. 287 ms). The framework's throughput is 288.7% higher than the baseline of ETL monolithic, and the average latency drops 72.5% to 245 ms compared to 892 ms for the baseline. An architectural assessment also shows that the system is more modular, loosely coupled, more fault isolated, and more flexible to deploy; all of which are important software quality attributes. The results indicate the proposed architecture as a potentially reusable reference to create scalable and intelligent ETL systems in enterprise data processing environments and emphasize the necessity of generalization in multi-domain validation.
Graphical Abstract
Keywords
Data Availability Statement
Funding
Conflicts of Interest
AI Use Statement
Ethical Approval and Consent to Participate
References
- Foidl, H., Golendukhina, V., Ramler, R., & Felderer, M. (2024). Data pipeline quality: Influencing factors, root causes of data-related issues, and processing problem areas for developers. Journal of Systems and Software, 207, 111855.
[CrossRef] [Google Scholar] - Ataei, P., & Staegemann, D. (2023). Application of microservices patterns to big data systems. Journal of Big Data, 10(1), 56.
[CrossRef] [Google Scholar] - Laigner, R., Kalinowski, M., Diniz, P., Barros, L., Cassino, C., Lemos, M., ... & Zhou, Y. (2020, August). From a monolithic big data system to a microservices event-driven architecture. In 2020 46th Euromicro conference on software engineering and advanced applications (SEAA) (pp. 213-220). IEEE.
[CrossRef] [Google Scholar] - Shahini, S., & Momeni, H. (2024). Autoencoder-based anomaly detection in microservices using distributed tracing. In 2024 IEEE 4th International Conference on Electronic Communications, Internet of Things and Big Data (ICEIB) (pp. 1–6). Taipei, Taiwan.
[CrossRef] [Google Scholar] - Liu, F. T., Ting, K. M., & Zhou, Z. H. (2012). Isolation-based anomaly detection. ACM Transactions on Knowledge Discovery from Data (TKDD), 6(1), 1-39.
[CrossRef] [Google Scholar] - Dapkute, A., Siozinys, V., Jonaitis, M., & Ostreika, D. (2024). Digital twin data management: Framework and performance metrics of cloud-based ETL system. Machines, 12(2), 130.
[CrossRef] [Google Scholar] - Pfister, B. J. J., Scheinert, D., Geldenhuys, M. K., & Kao, O. (2024). Daedalus: Self-adaptive horizontal autoscaling for resource efficiency of distributed stream processing systems. In Proceedings of the IEEE International Conference on Autonomic Computing and Self-Organizing Systems (ACSOS) (pp. 1–10). Aarhus, Denmark.
[CrossRef] [Google Scholar] - Garcia-Valls, M., Dubey, A., & Botti, V. (2024). A service mesh approach to integrate processing patterns into microservices applications. Cluster Computing, 27, 7417–7438.
[CrossRef] [Google Scholar] - Wen, R., Saleem, M., & Auer, S. (2024). Data pipeline approaches in serverless computing: A taxonomy, review, and research trends. Journal of Big Data, 11(82), 1–35.
[CrossRef] [Google Scholar] - Cao, Y., Xiang, H., Zhang, H., Zhu, Y., & Ting, K. M. (2025). Anomaly detection based on isolation mechanisms: A survey. Machine Intelligence Research, 22, 849–865.
[CrossRef] [Google Scholar] - Khan, M., Raza, A., & Ahmed, S. (2025). Enhancing data ingestion efficiency in cloud-based systems: A design pattern approach. Data Science and Engineering, 10, 1–18.
[CrossRef] [Google Scholar] - Rodrigues, H., Silva, A. R., & Avritzer, A. (2025). Assessment of performance and its scalability in microservice architectures: Systematic literature review. Journal of Systems and Software, 230, 112500.
[CrossRef] [Google Scholar] - Wang, H., Tangirala, G. K., Naidu, G. P., Mayville, C., Roy, A., Sun, J., & Mandava, R. B. (2024). Anomaly detection for incident response at scale. In Proceedings of the ACM SIGKDD International Conference on Knowledge Discovery and Data Mining (KDD) (pp. 1–8). Long Beach, CA, USA.
[CrossRef] [Google Scholar] - Ataei, P. (2024). Cybermycelium: A reference architecture for domain-driven distributed big data systems. Frontiers in Big Data, 7, 1448481.
[CrossRef] [Google Scholar] - Bouassida, S., Rekik, M., & Ben-Abdallah, H. (2024). Data integration from traditional to big data: Main features and comparisons of ETL approaches. The Journal of Supercomputing, 80, 26687–26725.
[CrossRef] [Google Scholar] - Hao, H., Chu, Z., Zhu, S., Jiang, G., Wang, Y., Jiang, C., Zhang, J. Y., Jiang, W., Xue, S., & Zhou, J. (2024). Continual learning in predictive autoscaling. In Proceedings of the ACM SIGKDD International Conference on Knowledge Discovery and Data Mining (KDD) (pp. 1–12). Long Beach, CA, USA.
[CrossRef] [Google Scholar]
Cite This Article
TY - JOUR AU - Manam, Karthik Babu PY - 2026 DA - 2026/07/14 TI - Scalable Software Engineering Architecture for AI-Enabled ETL Pipelines Using Event-Driven Microservices JO - ICCK Journal of Software Engineering T2 - ICCK Journal of Software Engineering JF - ICCK Journal of Software Engineering VL - 2 IS - 3 SP - 169 EP - 184 DO - 10.62762/JSE.2026.382038 UR - https://www.icck.org/article/abs/JSE.2026.382038 KW - Event-Driven architecture KW - microservices engineering KW - scalable ETL pipelines KW - AI-Enabled data transformation KW - distributed data processing KW - predictive load balancing KW - anomaly detection KW - container orchestration KW - software engineering frameworks KW - data quality management AB - As data ecosystems become more diverse and time-critical, traditional monolithic ETL pipelines face challenges to meet the demands of modern data engineering workloads in terms of scalability, adaptability, and operational resilience. In this paper, we introduce an event-driven microservices approach to orchestrate and deploy AI-based ETL (ETL = Extraction, Transformation, and Loading) pipelines in a Kubernetes-managed environment that includes the following components: asynchronous orchestration using Apache Kafka, hybrid anomaly detection, adaptive schema inference, and predictive load balancing. The proposed architecture breaks the ETL processing into loosely coupled services, which can be deployed and scaled independently, and incorporates data quality intelligence into the transformation layer. Two explicit baselines are used for experimental evaluation: (1) a traditional monolithic batch-processing ETL pipeline with sequential execution of the stages performed without horizontal scaling, and (2) an event-driven microservices pipeline, which uses Apache Kafka orchestration but no AI-enabled optimization modules. The framework is able to achieve 39.7% improvement in throughput (4,820 vs. 3,450 records/sec) and 96.3% anomaly detection accuracy, while reducing average E2E latency by 14.6% (245 vs. 287 ms). The framework's throughput is 288.7% higher than the baseline of ETL monolithic, and the average latency drops 72.5% to 245 ms compared to 892 ms for the baseline. An architectural assessment also shows that the system is more modular, loosely coupled, more fault isolated, and more flexible to deploy; all of which are important software quality attributes. The results indicate the proposed architecture as a potentially reusable reference to create scalable and intelligent ETL systems in enterprise data processing environments and emphasize the necessity of generalization in multi-domain validation. SN - 3069-1834 PB - Institute of Central Computation and Knowledge LA - English ER -
@article{Manam2026Scalable,
author = {Karthik Babu Manam},
title = {Scalable Software Engineering Architecture for AI-Enabled ETL Pipelines Using Event-Driven Microservices},
journal = {ICCK Journal of Software Engineering},
year = {2026},
volume = {2},
number = {3},
pages = {169-184},
doi = {10.62762/JSE.2026.382038},
url = {https://www.icck.org/article/abs/JSE.2026.382038},
abstract = {As data ecosystems become more diverse and time-critical, traditional monolithic ETL pipelines face challenges to meet the demands of modern data engineering workloads in terms of scalability, adaptability, and operational resilience. In this paper, we introduce an event-driven microservices approach to orchestrate and deploy AI-based ETL (ETL = Extraction, Transformation, and Loading) pipelines in a Kubernetes-managed environment that includes the following components: asynchronous orchestration using Apache Kafka, hybrid anomaly detection, adaptive schema inference, and predictive load balancing. The proposed architecture breaks the ETL processing into loosely coupled services, which can be deployed and scaled independently, and incorporates data quality intelligence into the transformation layer. Two explicit baselines are used for experimental evaluation: (1) a traditional monolithic batch-processing ETL pipeline with sequential execution of the stages performed without horizontal scaling, and (2) an event-driven microservices pipeline, which uses Apache Kafka orchestration but no AI-enabled optimization modules. The framework is able to achieve 39.7\% improvement in throughput (4,820 vs. 3,450 records/sec) and 96.3\% anomaly detection accuracy, while reducing average E2E latency by 14.6\% (245 vs. 287 ms). The framework's throughput is 288.7\% higher than the baseline of ETL monolithic, and the average latency drops 72.5\% to 245 ms compared to 892 ms for the baseline. An architectural assessment also shows that the system is more modular, loosely coupled, more fault isolated, and more flexible to deploy; all of which are important software quality attributes. The results indicate the proposed architecture as a potentially reusable reference to create scalable and intelligent ETL systems in enterprise data processing environments and emphasize the necessity of generalization in multi-domain validation.},
keywords = {Event-Driven architecture, microservices engineering, scalable ETL pipelines, AI-Enabled data transformation, distributed data processing, predictive load balancing, anomaly detection, container orchestration, software engineering frameworks, data quality management},
issn = {3069-1834},
publisher = {Institute of Central Computation and Knowledge}
}
Article Metrics
Publisher's Note
ICCK stays neutral with regard to jurisdictional claims in published maps and institutional affiliations.
Rights and Permissions
Copyright © 2026 by the Author(s). Published by Institute of Central Computation and Knowledge. This article is an open access article distributed under the terms and conditions of the Creative Commons Attribution (CC BY) license (https://creativecommons.org/licenses/by/4.0/), which permits use, sharing, adaptation, distribution and reproduction in any medium or format, as long as you give appropriate credit to the original author(s) and the source, provide a link to the Creative Commons licence, and indicate if changes were made.
Portico