Hi,
Below is the description about checkpointing.
『Checkpointing is guaranteed to only cover events that are fully
processed. It happens only when there are no pending process()/processAsync()
or WindowableTask.window() invocations. All preceding invocations happen-before
checkpointing and checkpointing happens-before all subsequent invocations.』
If one record can’t be sent out all the time, then the consumer will
still fetch messages or not, and what about the offset checkpointing?
Thanks!
————————
Qi Shu
