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