┌─────────────────────────────────┐   ┌────────────────────────────────────┐
┌─────────────────────────────────────────────────────────────────┐  ┌──────────────────────────────────────────────────────────────────────────────┐   ┌──────────────────┐   │Consumer                         │   │Producer                            │
│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         │   │language_binding : string           │
└─────────────────────────────────────────────────────────────────┘  └──────────────────────────────────────────────────────────────────────────────┘   └──────────────────┘   │flow_control_capability : boolean│   │backpressure_observability : boolean│
                                                                                                                                                                  |            └─────────────────────────────────┘   └────────────────────────────────────┘
                                                                                                                                                                  |                                                                                        
                                                                                                                                                                  |                                                                                        
                                                                                                                                                   ┌─────────────────────────────┐                        ┌──────────────────┐                             
                                                                                                                                                   │EventStream                  │                        │Event Data        │                             
                                                                                                                                                   ├─────────────────────────────┤                        ├──────────────────┤                             
                                                                                                                                                   │protocol_version : string    │                        │payload : string  │                             
                                                                                                                                                   │backpressure_signal : boolean│                        │timestamp : number│                             
                                                                                                                                                   └─────────────────────────────┘                        └──────────────────┘                             
                                                                                                                                                                  |                                                                                        
                                                                                                                                                     ┌─────────────────────────┐                                                                           
                                                                                                                                                     │Topic Metadata           │                                                                           
                                                                                                                                                     ├─────────────────────────┤                                                                           
                                                                                                                                                     │partition_count : number │                                                                           
                                                                                                                                                     │retention_period : string│                                                                           
                                                                                                                                                     └─────────────────────────┘