Hello, Working with flink checkpointing i see the messages discarded by a filter function are no acked for the checkpoint ack.
How can i auto confirm those discarded messages? The ack notification is trigged by a sink ? Thanks in advance!
Hello, Working with flink checkpointing i see the messages discarded by a filter function are no acked for the checkpoint ack.
How can i auto confirm those discarded messages? The ack notification is trigged by a sink ? Thanks in advance!