Andy Coates created KAFKA-10494:
-----------------------------------
Summary: Streams: enableSendingOldValues should not call parent if
node is itself materialized
Key: KAFKA-10494
URL: https://issues.apache.org/jira/browse/KAFKA-10494
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: Andy Coates
Calling `enableSendingOldValues` on many nodes, e.g. `KTableFilter`, is
unnecessarily calling `enableSendingOldValues` on the parent, even when the
processor itself is materialized. This can force the parent table to be
materialized unnecessarily.
For example:
```
StreamsBuilder builder = new StreamsBuilder();
builder
.table("t1", Consumed.of(...))
.filter(predicate, Materialized.as("t2"))
.<downStreamOps>
```
If `downStreamOps` result in a call to `enableSendingOldValues` on the table
returned by the `filter` call, i.e. `t2`, then it will result in `t1` being
materialized unnecessarily.
This ticket was raised off the back of [comments in a
PR](https://github.com/apache/kafka/pull/9156#discussion_r490152263) while
working on https://issues.apache.org/jira/browse/KAFKA-10077.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
