The data is coming directly from the exchange websocket connection. Because we are collecting data from multiple exchanges the symbols, timestamps etc. are different. To make a normalised data feed, we need to sanitize and make it in the common format. Also, sometime connection breaks randomly...