[
https://issues.apache.org/jira/browse/KAFKA-16366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sanghyeok An reassigned KAFKA-16366:
------------------------------------
Assignee: sanghyeok An
> 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
> Assignee: sanghyeok An
> Priority: Minor
>
> 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.
> https://issues.apache.org/jira/browse/KAFKA-16366#
> 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)