Tan-JiaLiang commented on PR #77:
URL: 
https://github.com/apache/flink-connector-kafka/pull/77#issuecomment-1899618447

   @MartijnVisser 
   Suppose there is a flink job that subscribes two topics in a source at the 
same time, TopicA and TopicB.
   
   * Write some data to both TopicA and TopicB.
   * Stop the job with savepoint, the offset of TopicA and TopicB will be saved 
in savepoint.
   * Now I change the subscribe topic list, subscribe only the TopicB, and 
restore from the last savepoint.
   * The Flink job will still consume the TopicA record, which will make user 
feel confused.
   
   So I think it is better to clearly tell the user that we cannot restore from 
the savepoint because the subscribe list has been changed.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to