Skip to content

v0.12.0

Compare
Choose a tag to compare
@bbalser bbalser released this 27 Feb 20:49
· 40 commits to master since this release
7e105c8
  • When a producer is started via Elsa.Supervisor, it is no longer guaranteed to be ready when supervisor returns. A new function Elsa.Producer.ready? will block until producer is ready.
  • Added feature to producer and simple consumer where elsa will poll for new partitions and react dynamically. A new field, poll, takes a time in milliseconds to configure how often elsa checks the number of partitions for a topic. This feature is disabled by default.
  • Changed process management to better handle connection issues with kafka
  • Fix bug related to shutting down elsa and making best attempt at completing processing of messages and committing offsets.