Matthias J. Sax created KAFKA-16366:
---------------------------------------
Summary: Refactor KTable source optimization
Key: KAFKA-16366
URL: https://issues.apache.org/jira/browse/KAFKA-16366
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: Matthias J. Sax
Kafka Streams DSL offers an optimization to re-use an input topic as table
changelog, in favor of creating a dedicated changelog topic.
So far, the Processor API did not support any such feature, and thus when the
DSL compiles down into a Topology, we needed to access topology internal stuff
to allow for this optimization.
With KIP-813 (merged for AK 3.8), we added `Topology#addReadOnlyStateStore` as
public API, and thus we should refactor the DSL compilation code, to use this
public API to build the `Topology` instead of internal APIs.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
