Hello all, I have created KIP-150 to facilitate discussion about adding cogroup to the streams DSL.
Please find the KIP here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-150+-+Kafka-Streams+Cogroup Please find my initial implementation here: https://github.com/KyleWinkelman/kafka Thanks, Kyle Winkelman