Distributed Event Stream Processing Pipeline

Design a scalable event stream processing system using Node.js that can handle high-volume data ingestion and real-time analytics. Implement a modular architecture supporting multiple data sources, with back-pressure handling, fault tolerance, and distributed processing capabilities. Create pluggable transformation modules that can perform complex event processing, including window-based aggregations, time-series decomposition, and anomaly detection. Include robust error handling, logging, and the ability to replay/reconstruct event streams.