Re: stream shutdown error

I am not 100% sure what you exactly do to upgrade to 2.1. But if you add a `suppress()` operator, you change your topology and therefore the old and new program is not compatible any longer. To avoid breaking changes like this, you can now (since 2.1) name all operators, stores, and changelog topi

stream shutdown error

Hi, I am use kafka stream new feature in kafka. My kafka vision : 2.0 My kafka-client vision : 2.1 But i can use the new feature : KIP-328-Final window results per key