Dear Kafka community, I am proposing KIP-267 to augment the public Streams test utils API. The goal is to simplify testing of Kafka Streams applications.
Please find details in the wiki:https://cwiki.apache.org/confluence/display/KAFKA/KIP-267%3A+Add+Processor+Unit+Test+Support+to+Kafka+Streams+Test+Utils An initial WIP PR can be found here:https://github.com/apache/kafka/pull/4662 I also included the user-list (please hit "reply-all" to include both lists in this KIP discussion). Thanks, -John