Boyang Chen created KAFKA-8236:
----------------------------------
Summary: Incorporate version control for Kafka Streams Application
Reset
Key: KAFKA-8236
URL: https://issues.apache.org/jira/browse/KAFKA-8236
Project: Kafka
Issue Type: Improvement
Reporter: Boyang Chen
Inspired by Spark mlflow which supports versioning log, we should be
considering expose a special versioning tag for KStream applications to easy
rollback bad code deploy. The naive approach is to store the versioning info in
consumer offset topic so that when we perform rollback, we know where to read
from the input, and where to cleanup the changelog topic. Essentially, this is
an extension to our current application reset tool.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)