I like the fact there are so many standard things in the streams package you can easily perform the pipes and filters design pattern to come up with a solution that works. There is so much available it is sometimes hard to find what you are looking for, but it's there already.
@marcpiechura In the gist I create a graph based on a number of partitions in my kafka source. I thought I could reuse this graph. I made a dictionary based on max partition count. But only 1 stream moved through the stream, all others invocations were completed from the start. Am I mistaken a graph can be reused, or am I doing something wrong?