[ https://issues.apache.org/jira/browse/KAFKA-2984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guozhang Wang resolved KAFKA-2984. ---------------------------------- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 672 [https://github.com/apache/kafka/pull/672] > KTable should send old values along with new values to downstreams > ------------------------------------------------------------------ > > Key: KAFKA-2984 > URL: https://issues.apache.org/jira/browse/KAFKA-2984 > Project: Kafka > Issue Type: Sub-task > Components: kafka streams > Affects Versions: 0.9.0.1 > Reporter: Yasuhiro Matsuda > Assignee: Yasuhiro Matsuda > Fix For: 0.9.1.0 > > > Old values are necessary for implementing aggregate functions. KTable should > augment an event with its old value. Basically KTable stream is a stream of > (key, (new value, old value)) internally. The old value may be omitted when > it is not used in the topology. -- This message was sent by Atlassian JIRA (v6.3.4#6332)