test topology stream processing with java8