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

Conversation

@ewencp
Copy link
Copy Markdown
Contributor

@ewencp ewencp commented Nov 9, 2015

No description provided.

@ewencp
Copy link
Copy Markdown
Contributor Author

ewencp commented Nov 10, 2015

@gwenshap We can probably live without this fix, but it's tiny and avoids generating errors in the logs. Would be nice to get it in before the RC.

@asfgit asfgit closed this in 590a461 Nov 10, 2015
asfgit pushed a commit that referenced this pull request Nov 10, 2015
…rkerSinkTask has finished starting up.

Author: Ewen Cheslack-Postava <me@ewencp.org>

Reviewers: Gwen Shapira

Closes #476 from ewencp/kafka-2786-on-partitions-assigned-only-after-start

(cherry picked from commit 590a461)
Signed-off-by: Gwen Shapira <cshapi@gmail.com>
ewencp referenced this pull request in confluentinc/kafka Nov 18, 2015
…rkerSinkTask has finished starting up.

Author: Ewen Cheslack-Postava <me@ewencp.org>

Reviewers: Gwen Shapira

Closes #476 from ewencp/kafka-2786-on-partitions-assigned-only-after-start
cmccabe pushed a commit to cmccabe/kafka that referenced this pull request Jan 13, 2021
This adds QuotaRecord to the controller along with validation logic for quota entities and quota keys. Some constants were factored out of the core scala code to allow reuse with the new quota manager in the metadata/controller module.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant