|
Hi,
I implement pub sub as source for flink with MessageAcknowledingSourceBase class. but when i want to display a simle log in notifyCheckpointComplete method nothing having. Processing finished with success but in deplucat i need to ack theses messages from pub sub with notifyCheckpointComplete .
Any help will be appreciated .
Regards
|