This project is a Zapier clone built using Node.js, Express, Typescript, Nextjs, Kafka with a microservices architecture. It enables users to create, manage, and execute automated workflows (zaps) that involve various actions and triggers.
Zapflow empowers users to automate their workflows with ease. Built on a microservices architecture, the application features a Primary Backend for user management and zap operations, a Hooks Service for executing zaps based on triggers, a Processor Service for monitoring zap execution, and a Worker Service that consumes messages from Kafka to perform actions.
Architecture
Communication between services is managed through REST APIs for synchronous interactions and Kafka for asynchronous processing, ensuring scalability and reliability in executing automated tasks.
Services
- Primary Backend: Handles user authentication and CRUD operations.
- Hooks Service: Executes zaps and logs execution.
- Processor Service: Monitors zap readiness and pushes data to Kafka.
- Worker Service: Consumes messages from Kafka and executes actions.