ords and all
>> checkpoint succeeded, no back pressure was incurred.
>>
>> In this case, if some machines crash, how does Flink recover the stalled
>> offsets? Which checkpoint does Flink rollback to? I understand that
>> commiting offset back to Kafka is merely to show p
Hi,
If your async operations are stalled, this will eventually cause problems.
Either this will back pressure sources (the async’s operator queue will become
full) or you will run out of memory (if you configured the queue’s capacity too
high). I think the only possible solution is to either
Hi Flink experts,
I am prototyping a real time system that reads from Kafka source with Flink
and calls out to an external system as part of the event processing. One of
the most important requirements are read from Kafka should NEVER stall,
even in face of some async external calls slowness
