José Valim
José Valim
It is not supported at the moment. Someone would need to make the current logic configurable.
Oh, to be clear, a PR to add this feature is welcome!
Yup, pretty much what I had in mind, except the accumulator is the second argument and instead of `:wrap`, we can call it `:done`. Should we just allow `batch_size` to...
Ship it!
Good point, we will probably need to support `:max_demand` to be given as an option too and use the same default we use throughout Broadway.
Hi @benkeil! We welcome folks to explore this idea. From your example above, the functionality that we would need is to add multiple producers of different types to a Broadway...
:green_heart: :blue_heart: :purple_heart: :yellow_heart: :heart:
DynamicSupervisor is not needed. You can add children to any supervisor while they are running. It won't be as fast as a dynamic one - but this is not like...
@fcevado no, you can still stop children in a regular supervisor without restarting. The restart is always about unexpected failures.
The only way to do that at the moment would be by restarting the pipeline. This is mostly OK except for Kafka which doesn't cope well with constant reconections.