I think it's because it's just taking the state for the existing topics and starts reading from that.
A workaround could be to change the uid of the operator to avoid reading the old state. Aljoscha > On 21. Feb 2018, at 02:21, Gyula Fóra <gyula.f...@gmail.com> wrote: > > Hi, > I have observed a weird behaviour when changing kafka topics when restoring > from a checkpoint. > > It seems that the job started consuming both the topics from the state, and > the new topic that I assigned. This happened while changing from kafka 08 to > kafka 10. > > Is this expected? > > Thanks, > Gyula
