You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm busy playing with Broadway for a use-case with many pipeline's that are created & destroyed dynamically. The changes introduced in dashbitco/broadway#239 seem perfect for this by allowing pipeline naming using a via tuple / Registry.
The broadway_kafka producer still assumes pipeline's are named using an atom, and tries to use Module.concat/2 to build it's own child process names.
Is there a sane way to get the Kafka producer to also support naming its children using the pipeline's process_name/2 function?
The text was updated successfully, but these errors were encountered:
Hello!
I'm busy playing with Broadway for a use-case with many pipeline's that are created & destroyed dynamically. The changes introduced in dashbitco/broadway#239 seem perfect for this by allowing pipeline naming using a via tuple / Registry.
The
broadway_kafka
producer still assumes pipeline's are named using an atom, and tries to useModule.concat/2
to build it's own child process names.Is there a sane way to get the Kafka producer to also support naming its children using the pipeline's
process_name/2
function?The text was updated successfully, but these errors were encountered: