Description
In shutdownTasksAndState we currently commit offsets as the first step. If a subsequent step throws an exception, i.e, flushing the producer, then this would violate the at-least-once guarantees.
We need to commit after all other state has been flushed
Attachments
Issue Links
- is duplicated by
-
KAFKA-4455 CommitFailedException during rebalance doesn't release resources in tasks/processors
- Resolved
- is related to
-
KAFKA-4455 CommitFailedException during rebalance doesn't release resources in tasks/processors
- Resolved
- links to