Did you changed the kafka group id? On Mon, Mar 19, 2018 at 9:54 PM, Aljoscha Krettek <aljos...@apache.org> wrote:
> 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 > >
