┌────────────────────────┐                                                                                                                                                                                                        ┌───────────────────────────────────┐
│Consumer                │  ┌─────────────────┐   ┌─────────────────────────────────────────────────────────────────┐   ┌──────────────────────────────────────────────────────────────────────────────┐   ┌──────────────────┐   │Producer                           │
├────────────────────────┤  │Platform Engineer│   │Wire-compatible with Kafka producer protocol for migration safety│   │Single binary, single config file, runs on a single node up to 100k events/sec│   │Apache 2.0 license│   ├───────────────────────────────────┤
│processing_rate : number│  │                 │   │                                                                 │   │                                                                              │   │                  │   │message_payload : string           │
│lag_status : string     │  └─────────────────┘   └─────────────────────────────────────────────────────────────────┘   └──────────────────────────────────────────────────────────────────────────────┘   └──────────────────┘   │backpressure_signal_input : boolean│
└────────────────────────┘                                                                                                                                                                                                        └───────────────────────────────────┘
                                                                                                                                                                                                                                                    |                  
                                                                                                                                                                                                                                                    |                  
                                                                                                          ┌─────────────────────────────┐                                                                                                   ┌──────────────┐           
                                                                                                          │EventStream                  │                                                                                                   │Event Message │           
                                                                                                          ├─────────────────────────────┤                                                                                                   ├──────────────┤           
                                                                                                          │protocol_version : string    │                                                                                                   │topic : string│           
                                                                                                          │backpressure_signal : boolean│                                                                                                   │key : string  │           
                                                                                                          └─────────────────────────────┘                                                                                                   │value : string│           
                                                                                                                                                                                                                                            └──────────────┘