Linkedin Databus Client

Linkedin Databus Client

To handle each partition there is a Relay Puller, Relay Dispatcher and Event buffer on the client. When getting data from a Bootstrap there is a Bootstrap Puller, Dispatcher and Event Buffer. Puller gets data from the Relay/Bootstrap and the event is stored in the event buffer. When the event buffer is full the Puller blocks. Dispatcher removes the events from the buffer and calls the callback driver. The callback driver will call all the consumers for that partition. Each consumer is called in parallel.