dashbitco/broadway

Issues

• Queurying topology can result in an exit if ets config store has not been initialized

  #349 opened a month ago by starbelly
  0

• Configurable Topology config storage

  #342 opened 4 months ago by chasers
  5

• GenStage 1.2.0 breaks tests

  #340 opened 9 months ago by whatyouhide
  3

• Batcher Concurrency based on batcher_key

  #337 opened 10 months ago by OctopusRage
  2

• C

  #336 opened 10 months ago by OctopusRage
  0

• Add `terminate/3` callback

  #319 opened a year ago by type1fool
  11

• `handle_message` timeout

  #335 opened a year ago by acco
  2

• Issues using Broadway with DynamicSupervisor

  #332 opened a year ago by themusicman
  0

• Request for MQTT support in Elixir Broadway

  #330 opened a year ago by Enuzo
  3

• Allow support for Nimble Options 1.0

  #322 opened 2 years ago by aselder
  5

• Use Broadway for stream processing

  #264 opened 2 years ago by benkeil
  3

• Oban producer

  #320 opened 2 years ago by joevandyk
  3

• Resize broadway pipeline

  #228 opened 4 years ago by fcevado
  8

• Broadway v1.0.4 Broadway.NoopAcknowledger returns NoopAcknowledger instead of Broadway.NoopAcknowledger

  #315 opened 2 years ago by seantanly
  1

• Byte size batching

  #255 opened 2 years ago by cleaton
  11

• Dialyzer error on ack_immediately/1

  #314 opened 2 years ago by mortont
  3

• Expected Behavior on Startup?

  #311 opened 2 years ago by zbruhnke
  4

• [docs] The `Broadway.test_batch` example doesn't work with Broadway 1.0.3

  #312 opened 2 years ago by moniquelive
  3

• Telemetry distinguish between Producer metrics

  #307 opened 3 years ago by spencerdcarlson
  2

• Disable automatic call to handle_batch/4

  #305 opened 3 years ago by rogerweb
  2

• [Question] Creating a Broadway Message struct for testing?

  #306 opened 3 years ago by mattmartian
  0

• Broadway.update_rate_limit doesn't reset the counter/interval right away

  #300 opened 3 years ago by acco
  3

• NoopAcknowledger fails with ack key being set

  #302 opened 3 years ago by LostKobrakai
  7

• Make producer module a keyword list to ease configuration management?

  #296 opened 3 years ago by yordis
  6

• How to stop a Broadway Kafka pipeline?

  #292 opened 3 years ago by aravindanck
  1

• [Question] how am i able to update a message in handle_failed and send to another batcher?

  #284 opened 3 years ago by mattmartian
  1

• Allow use of nimble_options 0.4.0

  #283 opened 3 years ago by cliftonmcintosh
  2

• Possibility to update Pipeline :context ?

  #282 opened 3 years ago by ifoo
  1

• 1->n message processing

  #280 opened 3 years ago by ilgarm
  3

• Clarification about concurrency in multi-node deployments

  #275 opened 3 years ago by mathiasose
  1

• Support hot-reloads to scale stages

  #279 opened 3 years ago
  2

• Pipeline design

  #278 opened 3 years ago by samuelmanzanera
  2

• Broadway kafka example is not working as expected

  #274 opened 3 years ago by guigaoliveira
  2

• test_batch function not accepting pid

  #273 opened 3 years ago by atomkirk
  1

• Request for 1.0.1 Release

  #272 opened 3 years ago by robertkeizer
  1

• The intention of random subscription in Subscriber does not work as expected

  #269 opened 3 years ago by kenspirit
  16

• Unable to checkout db connection for Broadway

  #218 opened 3 years ago by michaelst
  9

• Multiple Pipelines

  #265 opened 4 years ago by benkeil
  5

• Monitoring batches that were consumed after timeout

  #253 opened 4 years ago by guigaoliveira
  3

• Broadway.all_running returns an error when Named (via_tuple) Broadway pipeline

  #252 opened 4 years ago by gabrielmancini
  0

• Stop a Named (via_tuple) Broadway pipeline and some questions

  #251 opened 4 years ago by gabrielmancini
  1

• Exposing the `:context` value to emitted Telemetry events

  #245 opened 4 years ago by CaptainCuddleCube
  2

• `[:broadway, :processor, :message, :stop]` docs incorrect

  #240 opened 4 years ago by darrenclark
  1

• Let the Producer shut down the pipeline

  #242 opened 4 years ago by acco
  2

• Using via_tuple as `name`

  #236 opened 4 years ago by acco
  8

• Add Broadway.stop

  #215 opened 4 years ago by josevalim
  3

• Using ETS over process dictionary when batching events?

  #230 opened 4 years ago by woojiahao
  1

• Pipeline specific Ack

  #227 opened 4 years ago by Hajto
  1

• `:transformer` is skipped when pushing messages using `Broadway.test_message/3`

  #225 opened 4 years ago by Hajto
  2

• Telemetry events for producers?

  #221 opened 4 years ago by samullen
  1