Hey Xiyuan, I would assume it's easier for us to help you by reading your application with a full paste of code (a prototype). Changing application id would work suggests that re-process all the data again shall work, do I understand that correctly?
Boyang On Wed, Sep 25, 2019 at 8:16 AM Xiyuan Hu <xiyuan.h...@gmail.com> wrote: > Hi, > > I'm running a Kafka streams app(v2.1.0) with windowed function(reduce > and suppress). One thing I noticed is, every time when I redeployment > or restart the application, I have to change the application ID to a > new one, otherwise, only the reduce-repartition internal topic has > input traffic(and it has no out-traffic), all other internal topics > has no traffic as all. Looks like it just flows into the first > internal repartition topic(reduce-repartiton), the reduce-changelog > has no traffic and no output traffic as well. > > Could anyone know what's wrong with it? Changing application Id and > create new internal topics each time seems not the right thing to go > with. > > I started the app like below: > > streams = new KafkaStreams(topology.getTopology(config), > properties.getProperties()); > streams.start(); > > Any help would be appreciated! Thanks! >
