Hi all, I am proposing a new optimization to Kafka Streams which would greatly reduce the number of idempotent updates (or no-ops) in the Kafka Streams DAG. A number of users have been interested in this feature, so it would be nice to pass this one in.
For information, the KIP is described below: https://cwiki.apache.org/confluence/display/KAFKA/KIP-557%3A+Add+emit+on+change+support+for+Kafka+Streams We aim to make Kafka Streams more efficient by adopting the "emit on change" reporting strategy. Please cast your vote! Best, Richard