Hi everybody! I'd like to propose a change that we probably should've added for a long time now.
The key benefit of this KIP would be reduced traffic in Kafka Streams since a lot of no-op results would no longer be sent downstream. Here is the KIP for reference. https://cwiki.apache.org/confluence/display/KAFKA/KIP-557%3A+Add+emit+on+change+support+for+Kafka+Streams Currently, I seek to formalize our approach for this KIP first before we determine concrete API additions / configurations. Some configs might warrant adding, whiles others are not necessary since adding them would only increase complexity of Kafka Streams. Cheers, Richard
