The PR added the additional server time info to the checkpoints generated by the pg source,
so the application could use the timestamp info to check if it is continuously consuming the events (including the KeepAlive messages) from the pg source.
One of the usage of such the feature is to help setting up the readiness probe in the k8s deployment.
Description
The PR added the additional server time info to the checkpoints generated by the pg source, so the application could use the timestamp info to check if it is continuously consuming the events (including the KeepAlive messages) from the pg source.
One of the usage of such the feature is to help setting up the readiness probe in the k8s deployment.