It took me 2 days to figure this out. The solution is this imho https://cwiki.apache.org/confluence/display/KAFKA/KIP-150+-+Kafka-Streams+Cogroup