Once websockets get implement the following flow should be modelled: 1. read from kafka 2. process 3. send to websocket