The exponential growth of real-time data streams from digital platforms, Internet of Things (IoT) devices, and enterprise applications has redefined the requirements for big data analytics. Traditional batch-processing architectures, while robust for historical analysis, are increasingly insufficient in addressing the need for low-latency decision-making in sectors such as finance, healthcare, telecommunications, and e-commerce. Consequently, resilient streaming data pipelines have become critical in supporting fault-tolerant, scalable, and high-throughput analytics. This study explores the design and implementation of resilient, low-latency data pipelines for streaming big data analytics by leveraging the Apache Kafka and Apache Spark ecosystems. Kafka, a distributed publish-subscribe messaging system, provides durable, fault-tolerant ingestion capabilities with strong scalability properties, while Spark Structured Streaming delivers near real-time analytical processing and advanced machine learning integration. Together, these technologies form a complementary foundation for constructing streaming pipelines capable of handling large volumes of high-velocity data. The paper discusses architectural design principles, including partitioning strategies, replication for fault tolerance, stateful stream processing, and backpressure handling. It further evaluates techniques for ensuring end-to-end resilience, such as exactly-once semantics, checkpointing, and integration with containerized environments like Kubernetes for deployment scalability. Case study insights highlight latency benchmarks and system performance under varying workloads, demonstrating how the Kafka-Spark integration supports enterprise-grade analytics. By uniting resilience, scalability, and analytical depth, the proposed pipeline framework enables organizations to harness real-time insights while ensuring reliability under fluctuating conditions. The findings contribute practical guidelines for architects, engineers, and decision-makers seeking to operationalize streaming analytics infrastructures that meet the growing demands of modern data-driven enterprises.
Uju Ugonna Uzoagu (Tue,) studied this question.
Synapse has enriched 5 closely related papers on similar clinical questions. Consider them for comparative context: