Skip to content
Open access

Scalable Software Engineering Architecture for AI-Enabled ETL Pipelines Using Event-Driven Microservices

Jul 2026 · ICCK Journal of Software Engineering · Vol 2, pp. 169-184 · 0 citations

TL;DR

An event-driven microservices approach to orchestrate and deploy AI-based ETL 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.

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.

Read PDF

Similar papers

Open access Sep 2026

Serverless Data Engineering: Innovations in Python-Driven ETL Automation on AWS

The central argument is that serverless ETL does not simplify data engineering; it redistributes engineering effort from infrastructure management to execution model design, and Lambda timeout decomposition, cold start management, Glue worker right-sizing, IAM role scoping, and Step Functions state machine cost design...

Rambabu Bolineni · 0 citations
Open access 2024

AI-Assisted Data Pipeline Orchestration for Scalable Analytics

The study concludes that AI-driven orchestration is a promising approach for building scalable and autonomous data processing systems, with future work focusing on deeper integration of advanced learning models and real-time adaptability.

J. Weizenbaum, S. Papert · 1 citation
Open access 2019

Continuous Data Transformation in Event-Driven Microservices

This paper presents real-world use cases, compares toolsets such as Apache Kafka Streams, Apache Flink, Debezium, and AWS Kinesis, and proposes a reference architecture to guide practitioners in designing scalable transformation pipelines.

Thabo Nkosi · 0 citations
Conference Jul 2026

Intelligent Data Engineering Pipelines for Enterprise Applications: Architecture Challenges and Optimization Strategies

The rapid growth of enterprise applications has led to a substantial increase in the volume, velocity, and variety of data, necessitating intelligent data engineering pipelines for efficient processing and analytics. These pipelines play a critical role in enabling scalable data integration, transformation, and deliver...

D. Bansal, Dinesh Kumar Garg · 0 citations
Open access 2020

Cloud-Native Data Pipelines for Enterprise Analytics

An organized approach to the design and deployment of cloud-native data pipelines with the inclusion of data quality management, security controls, observability, and cost optimization is suggested, and throughput, latency and scalability modeling mathematical formulations are proposed in order to facilitate capacity p...

Ethan Williams · 0 citations
Conference Jul 2026

Agentic Data Services: A Control-Plane Architecture for Adaptive Data Workflows

Modern data platforms rely on pipeline-oriented architectures that are rigid, hard to adapt, and lack native auditability. We present Agentic Data Services, a control-planedriven architecture for Big Data as a Service (BDaaS) that models workflows as adaptive, policy-aware service entities rather than static directed a...

Alexander Chernov · 0 citations

We use cookies to run the site and, with your consent, for analytics and to show ads. See our Cookie Policy.