Skip to content

KAFKA-2748: Ensure sink tasks commit offsets upon rebalance and rewind if the SinkTask flush fails.#431

Closed
ewencp wants to merge 2 commits intoapache:trunkfrom
ewencp:kafka-2748-sink-task-rebalance-commit
Closed

KAFKA-2748: Ensure sink tasks commit offsets upon rebalance and rewind if the SinkTask flush fails.#431
ewencp wants to merge 2 commits intoapache:trunkfrom
ewencp:kafka-2748-sink-task-rebalance-commit

Commits

Commits on Nov 5, 2015