Thanks for the reply, Nico. I've been testing with OffsetCommitMode.ON_CHECKPOINTS, and I can confirm that this fixes the issue -- even if a single commit time out when communicating with Kafka, subsequent offset commits are still successful.
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
