Changelog

Copy Markdown View Source

2.0.0 (2026-08-16)

⚠ BREAKING CHANGES

  • reworked option handling (#86)
  • upgrade to pulsar-elixir 3.x (#79)

Features

  • stop asking for messages while draining (98fc392)
  • upgrade to pulsar-elixir 3.x (#79) (10c0a34)

Bug Fixes

  • do not crash the stage on an unexpected message (bc87cd9)
  • survive loss of a consumer worker (#88) (4ba8a8f)
  • tie consumer lifetime to the stage (#81) (eb93b72)

Performance Improvements

  • use a queue for the producer message buffer (47e9ea6)

Dependencies

  • bump styler from 1.11.0 to 1.12.1 (#74) (67381b4)
  • bump styler from 1.12.1 to 1.12.2 (#76) (d5f0ed7)
  • ci: bump jdx/mise-action from 4 to 4.2.3 (#77) (6ae4ff7)
  • ci: bump jdx/mise-action from 4.2.3 to 4.2.4 (#78) (38488bc)
  • ci: bump jdx/mise-action from 4.2.4 to 4.2.5 (#85) (103685b)
  • docker: bump apachepulsar/pulsar from 4.0.2 to 4.2.4 (#84) (6543060)

Documentation

  • add 1.x to 2.x upgrade guidelines (463e928)
  • extend docs about manual flow control (#87) (4a367d2)
  • publish the changelog with the generated docs (ae95286)

Code Refactoring

  • reworked option handling (#86) (1de8748)
  • validate option in prepare_for_start/2 (5fdd033)

Tests

Continuous Integration

  • configure dependabot to bump docker-compose deps (7a2b532)

Miscellaneous Chores

  • add configuration section to readme file (c98dc47)
  • examples: add atproto e2e example (#82) (4c5842a)

1.5.1 (2026-07-20)

Dependencies

1.5.0 (2026-07-19)

Features

  • failover active state change callback (#70) (fcba675)

Dependencies

  • bump pulsar from 2.10.1 to 2.11.0 (#69) (03b6e8a)
  • bump pulsar from 2.9.0 to 2.10.1 (#67) (26e99ed)
  • ci: bump actions/cache from 5 to 6 (#68) (8e3f33d)
  • ci: bump actions/checkout from 6 to 7 (#65) (85e5949)

1.4.0 (2026-06-06)

Features

  • pulsar: partition auto-discovery (54fb1b3)

Bug Fixes

  • permit tracking is off for partitioned topics (9b297ad)

Dependencies

  • bump erlang and elixir versions to 29 and 1.20 (#63) (ca4ad2c)
  • bump pulsar from 2.8.17 to 2.9.0 (070859f)
  • ci: bump actions/cache from 4 to 5 (#61) (7ca760f)
  • ci: bump actions/checkout from 4 to 6 (#58) (ff23dd2)
  • ci: bump dorny/test-reporter from 2.2.0 to 3.0.0 (#59) (fa55abd)
  • ci: bump jdx/mise-action from 2 to 4 (#62) (63eb14d)

Continuous Integration

  • bump version in readme on new release (#56) (3e98430)
  • configure dependabot to bump gha dependencies (#57) (c44afb7)
  • migrate releases to release-please (#54) (8b28f9a)

1.3.11 (2026-06-05)

1.3.10 (2026-05-23)

1.3.9 (2026-05-21)

1.3.8 (2026-05-21)

1.3.7 (2026-05-21)

1.3.6 (2026-05-08)

Bug Fixes

  • inherit default callbacks for pulsar consumer (#48) (1b1e4fb)

1.3.5 (2026-03-22)

1.3.4 (2026-03-10)

1.3.3 (2026-03-05)

1.3.2 (2026-03-04)

1.3.1 (2026-02-28)

1.3.0 (2026-02-27)

Features

  • add support for multi-topic producers (#39) (7e37e29)

1.2.11 (2026-02-27)

1.2.10 (2026-02-20)

1.2.9 (2026-02-04)

1.2.8 (2026-02-03)

1.2.7 (2026-01-29)

1.2.6 (2026-01-22)

1.2.5 (2026-01-22)

1.2.4 (2026-01-09)

1.2.3 (2025-12-27)

1.2.2 (2025-12-18)

1.2.1 (2025-12-15)

Bug Fixes

  • missing chunking-related options (296d462)
  • missing compaction-related settings (8868e05)

1.2.0 (2025-12-14)

Features

  • add support for message chunking (29facd1)

1.1.0 (2025-12-06)

Features

  • support pulsar-elixir multi-client architecture (93ba3fc)

1.0.4 (2025-12-05)

1.0.3 (2025-12-05)

1.0.2 (2025-12-05)

1.0.1 (2025-12-05)

1.0.0 (2025-12-05)

Features

  • optional pulsar connection (0ebb96b)
  • producer concurrency (d430692)
  • support all pulsar-elixir options (454d20e)

Bug Fixes

  • align demand handling with pulsar native flow control (f9ba1de)
  • back pressure bug (40faa92)
  • batched acknowledgements (a2a094e)
  • dispatch message when pipeline waiting for demand (0484272)
  • dispatch messages in order (d805b98)
  • do not ignore startup delay and jitter (10097ec)
  • do not start pulsar app automatically (ffb8c22)
  • dynamic pulsar consumer process (a632b1e)
  • only dispatch messages based on demand (81d34e9)
  • pipeline stops on consumer restart (42e0324)
  • stale consumer when using DLQ policy (da89a9d)
  • wrong function clause in consumer (f2e1625)