Skip to content

Tags: karafka/waterdrop

Tags

v2.10.1

Toggle v2.10.1's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Fix Producer#close raising ThreadError when called from a signal trap…

… context (#867)

Puma's `after_stopped` DSL hook in single mode runs in a Ruby signal trap context.
Ruby forbids Mutex#synchronize from trap contexts and raises:
  ThreadError: can't be called from trap context

Producer#close calls @transaction_mutex.synchronize, which hits this restriction.

The fix rescues ThreadError at the method level and re-runs close in a background
thread, joining it so the caller blocks until the producer is fully closed. This
mirrors the existing pattern used to escape the fd-poller thread deadlock.

Closes #866

v2.10.0

Toggle v2.10.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
v2.10.0 (#859)

v2.9.0

Toggle v2.9.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Update CHANGELOG.md

Signed-off-by: Maciej Mensfeld <maciej@mensfeld.pl>

v2.8.16

Toggle v2.8.16's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
v2.8.16 (#799)

v2.8.15

Toggle v2.8.15's commit message

Verified

This commit was signed with the committer’s verified signature.
mensfeld Maciej Mensfeld
fix release date

v2.8.14

Toggle v2.8.14's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
v2.8.14 (#724)

v2.8.13

Toggle v2.8.13's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
v2.8.13 (#715)

v2.8.12

Toggle v2.8.12's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
v2.8.12 (#705)

v2.8.11

Toggle v2.8.11's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
v2.8.11 (#698)

v2.8.10

Toggle v2.8.10's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
v2.8.10 (#693)