kestra-io / kestra-io/plugin-pulsar
plugin-pulsar: kill()/stop() not implemented on killable/pollable tasks
Open
area/plugin
kind/cooldown
- Dominant language
- Java
- Stars
- 2
- Forks
- 10
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 5
Description
Sub-issue of kestra-io/kestra-ee#10964.
**Tasks:** io.kestra.plugin.pulsar.Consume
**Why:** Long-lived Pulsar consume loop; no kill()/stop() to close the consumer early.
**Fix:** override `kill()` and/or `stop()` on these task classes to cancel the poll loop / close the consumer / cancel the remote job. See `io.kestra.plugin.gcp.bigquery.AbstractBigquery` for a reference implementation.
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.