Event consuming is now stream based. Allows for larger transactions in consumer
Used Java 8 primitives (Stream and Block) in more places