You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2017/11/05 23:41:00 UTC
[jira] [Assigned] (KAFKA-5581) Avoid creating changelog topics for
state stores that are materialized from a source topic
[ https://issues.apache.org/jira/browse/KAFKA-5581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jeyhun Karimov reassigned KAFKA-5581:
-------------------------------------
Assignee: Jeyhun Karimov
> Avoid creating changelog topics for state stores that are materialized from a source topic
> ------------------------------------------------------------------------------------------
>
> Key: KAFKA-5581
> URL: https://issues.apache.org/jira/browse/KAFKA-5581
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Guozhang Wang
> Assignee: Jeyhun Karimov
> Labels: architecture, performance
>
> Today Streams make all state stores to be backed by a changelog topic by default unless users overrides it by {{disableLogging}} when creating the state store / materializing the KTable. However there are a few cases where a separate changelog topic would not be required as we can re-use an existing topic for that. A few examples:
> There are a few places where the materialized store do not need a separate changelog topic. This issue summarize a specific issue:
> 1) If a KTable is read directly from a source topic, and is materialized i.e.
> {code}
> table1 = builder.table("topic1", "store1")`.
> {code}
> In this case {{table1}}'s changelog topic can just be {{topic1}}, and we do not need to create a separate {{table1-changelog}} topic.
> 2) if a KStream is materialized for joins where the streams are directly from a topic, e.g.:
> {code}
> stream1 = builder.stream("topic1");
> stream2 = builder.stream("topic2");
> stream3 = stream1.join(stream2, windows); // stream1 and stream2 are materialized with a changelog topic
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)