[
https://issues.apache.org/jira/browse/KAFKA-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3870:
--------------------------------
Description:
Currently in Kafka Streams the state store names are hidden in the DSL. This
JIRA proposes to make them visible to the DSL, so that developers can
subsequently query them. Sequence of steps:
- Explicitly require names for all operations that create a state store, like
{{aggregate}}.
- Explicitly require names for all created KTables (thus their changelog state
stores)
- Materialize all KTables (today some KTables are materialized and some are not)
was:The class {{org.apache.kafka.streams.kstream.Windows}} takes a "name"
parameter that specifies the name of state stores for any subsequent
operations. It is better to remove the name from this class and add it to the
aggregator or join operators instead.
> Expose state store names to DSL
> -------------------------------
>
> Key: KAFKA-3870
> URL: https://issues.apache.org/jira/browse/KAFKA-3870
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Affects Versions: 0.10.1.0
> Reporter: Eno Thereska
> Assignee: Eno Thereska
> Fix For: 0.10.1.0
>
>
> Currently in Kafka Streams the state store names are hidden in the DSL. This
> JIRA proposes to make them visible to the DSL, so that developers can
> subsequently query them. Sequence of steps:
> - Explicitly require names for all operations that create a state store, like
> {{aggregate}}.
> - Explicitly require names for all created KTables (thus their changelog
> state stores)
> - Materialize all KTables (today some KTables are materialized and some are
> not)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
