You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/10/18 17:20:00 UTC
[jira] [Resolved] (KAFKA-7424) State stores restoring from
changelog topic not the source topic
[ https://issues.apache.org/jira/browse/KAFKA-7424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Matthias J. Sax resolved KAFKA-7424.
------------------------------------
Resolution: Fixed
[~jhay], [~vvcephei]: I am closing this ticket as it seems to be covered via KAFKA-6729.
If you disagree, feel free to reopen and provide more context on the issue.
> State stores restoring from changelog topic not the source topic
> ----------------------------------------------------------------
>
> Key: KAFKA-7424
> URL: https://issues.apache.org/jira/browse/KAFKA-7424
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 1.1.1
> Reporter: James Hay
> Priority: Critical
>
> Hi,
>
> I've recently attempted to upgrade a streams application form 1.1 to 1.1.1 and I noticed a drop in the number of messages being restored in our state stores.
> It appears that there is a change in 1.1.1 which causes our state stores to be restored from the changelog topic as opposed to version 1.1 where the stores are restored from the source topic. In our application this causes an issue as we switched to StreamsBuilder from KStreamBuilder in the middle of the applications lifetime and so the changelog doesn't represent a full history of the source topic.
> Has this switch been introduced intentionally? Is there a way to configure our application to use 1.1.1 and still use the source stream to restore state stores? Any recommendations on getting our changelog in sync with the source?
>
> Thanks
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)