Guozhang Wang created KAFKA-7502:
------------------------------------
Summary: Cleanup KTable materialization logic in a single place
Key: KAFKA-7502
URL: https://issues.apache.org/jira/browse/KAFKA-7502
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: Guozhang Wang
Today since we pre-create all the `KTableXXX` operator along with the logical
node, we are effectively duplicating the logic to determine whether the
resulted KTable should be materialized. For example, in `KTableKTableJoinNode`
and in `KTableImpl#doJoin`. This is bug-vulnerable since we may update the
logic in one class but forgot to update the other class.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
