Skip to content

KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the WorkerSinkTask has finished starting up.#476

Closed
ewencp wants to merge 1 commit intoapache:trunkfrom
ewencp:kafka-2786-on-partitions-assigned-only-after-start
Closed

KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the WorkerSinkTask has finished starting up.#476
ewencp wants to merge 1 commit intoapache:trunkfrom
ewencp:kafka-2786-on-partitions-assigned-only-after-start