Skip to content

KAFKA-2713: Run task start and stop methods in worker threads so they execute in parallel and cannot block the herder thread.#443

Closed
ewencp wants to merge 1 commit intoapache:trunkfrom
ewencp:kafka-2713-task-start-stop-threaded
Closed

KAFKA-2713: Run task start and stop methods in worker threads so they execute in parallel and cannot block the herder thread.#443
ewencp wants to merge 1 commit intoapache:trunkfrom
ewencp:kafka-2713-task-start-stop-threaded

Conversation

@ewencp
Copy link
Copy Markdown
Contributor

@ewencp ewencp commented Nov 6, 2015

No description provided.

… execute in parallel and cannot block the herder thread.
@ewencp
Copy link
Copy Markdown
Contributor Author

ewencp commented Nov 6, 2015

@gwenshap @guozhangwang This is one of the blockers for getting #432 merged.

@gwenshap
Copy link
Copy Markdown
Contributor

gwenshap commented Nov 6, 2015

LGTM

@asfgit asfgit closed this in a76660a Nov 6, 2015
efeg added a commit to efeg/kafka that referenced this pull request Jan 29, 2020
hachikuji pushed a commit to hachikuji/kafka that referenced this pull request Nov 3, 2020
wyuka pushed a commit to wyuka/kafka that referenced this pull request Mar 22, 2023
This should be a direct fix up to the commit
- 28cca3e Cancellation of reassignments allowed if the resulting ISR is at min-ISR (apache#442)
davide-armand pushed a commit to aiven/kafka that referenced this pull request Dec 1, 2025
…he#443)

* fix(inkless): close missing resources in tests

* refactor(inkless): pass single metrics to storage implementations

Main change changing how the StorageBackend is istantiated via
reflection by passing an existing metrics instance.

* chore: update docs

* fixup! refactor(inkless): pass single metrics to storage implementations

* fixup! refactor(inkless): pass single metrics to storage implementations
jeqo added a commit to aiven/kafka that referenced this pull request Jan 16, 2026
…he#443)

* fix(inkless): close missing resources in tests

* refactor(inkless): pass single metrics to storage implementations

Main change changing how the StorageBackend is istantiated via
reflection by passing an existing metrics instance.

* chore: update docs

* fixup! refactor(inkless): pass single metrics to storage implementations

* fixup! refactor(inkless): pass single metrics to storage implementations
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.

2 participants