Adaptable parsing of real-time data streams