git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

checkpoint recovery behavior when kafka source is set to start from timestamp


Hi Experts,


In my application, the kafka source is set to start from a specified timestamp, by calling method FlinkKafkaConsumer010#setStartFromTimestamp(long startupOffsetsTimestamp). 


If the application have run a while and then recover from a checkpoint because of failure, what's the offset will the kafka source to read from? I suppose it will read from the offset that has been committed before the failure. Is it right? 


I am going to verify it, however some clarification is good in case my test result doesn't meet my assumption.


Best

Yan




( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-flink-users/msg11209.html on line 93
Call Stack
#TimeMemoryFunctionLocation
10.0006364632{main}( ).../msg11209.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-flink-users/msg11209.html on line 93
Call Stack
#TimeMemoryFunctionLocation
10.0006364632{main}( ).../msg11209.html:0