Letitpe -

pipeline: - middleware: logger

| Term | Definition | |------|------------| | | A structured data payload that flows through LetItPe. Every event has a type , version , and payload . | | Source | An inbound connector (Kafka topic, HTTP webhook, SQS queue, etc.) that produces events. | | Sink | An outbound connector where events are emitted after processing (e.g., another topic, a webhook, a database). | | Processor | User‑provided function that receives an event, optionally mutates it, and returns a (possibly new) event. | | Pipeline | An ordered series of middleware + processors that an event traverses from source to sink. | | Schema Registry | Centralised store (optional) for JSON‑Schema / Protobuf definitions used for validation & versioning. | | DLQ (Dead‑Letter Queue) | A dedicated sink for events that could not be processed after all retries. | | Replay Engine | Built‑in tool to replay stored events (from a durable log) for debugging or migration. | letitpe

Running the service: