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!
