Type-Safe, Versioned, and Rewindable Stream Processing

Quick and reliable data processing keeps businesses at the forefront of their industry. Applications and their data continuously change in the face of non-stop near-real-time analysis requirements. This can pose major delays for businesses and cost money. We present some of these difficulties and address how we use versioning, evolution, and type safety to processing streams and allow for data-replay; with Avro, Kafka, and Scala.