Hi All, Samza currently doesn't have a way to gracefully drain pipelines before making a backward-incompatible intermediate schema change. We have added a feature called Pipeline Drain to the samza engine to address this problem. Here is the SEP page for it: https://cwiki.apache.org/confluence/display/SAMZA/SEP-31%3A+Pipeline+Drain%3A+Support+the+ability+to+drain+pipelines+to+allow+incompatible+intermediate+schema+changes
If there are no major blockers, we are tentatively seeking to open a vote on Monday, Nov 28th, 2022. Thanks, Ajo
